task-queue

    0

    1答えて

    Twitter APIを使用することについてnode.jsを使用してアプリケーションを作成しています。以下のような 機能: app.get('/api/get_follower', function(req, res){ var username = req.query.username var client = new twitter({ consumer_key

    1

    1答えて

    ジョブから複数のジョブを生成することは安全ですか?ワーカーは空いているジョブの作業を開始できますか? 現在、私のセットアップは次のようなものです。私は20人の労働者がどんな仕事が押されるのを待っている。仕事の1つは、IOSのプッシュ通知、iOSの問題を送信することです、あなたは一括メッセージを送信することはできません。 Current:私が作ったのは、特定のユーザーのリストをバッチで取得し、dbか

    0

    1答えて

    長時間実行しているタスクを実行し、タスクをタスクキューにプッシュするアプリケーションがあります。現在、異なるユーザーがアプリケーションにログインしてアップロードジョブを開始すると、ジョブは既存のタスクとマージされ、予想される出力は達成されません。 私が正確に必要とするのは、すべてのユーザーが大量の計算能力を必要とし、新しいユーザーが出現するたびにこれらのインスタンスを動的に作成する必要があるため、

    1

    1答えて

    私が達成しようとしているものは、ユーザーが従業員が処理するバッチ処理を動的に実行できるマルチテナントアプリケーションを構築しています。私たちは、一人のユーザからの単一のバッチを持っている場合 は、すべての労働者は、この単一のユーザー からのメッセージ上で動作している別のユーザーがバッチジョブを送信する場合、各ユーザーは、労働者の半分を取得します(最初のユーザーはあるように現在遅い速度で作業していま

    5

    1答えて

    Windows ServerのMicrosoft Message Queueで新しく、EmployeeIDがNULLの場合はプッシュする必要があります。 従業員モデルクラスは、データがその検証例外キュー内に押し込まれると、それは別のプロセスによって処理されるべき public class Employee { public string EmployeeID { get; set; }

    1

    1答えて

    一般的なタスクキュー(Google GAE TaskQueue、Celeryなど)にはETA/Countdown機能があり、xxx秒後にタスクをキューに入れることができます。 私はETA機能を備えたタスクキューを必要とするプロジェクトに取り組んでいます。しかし、私はGoogleのPubsubメッセージングシステムを使用する必要がいくつかの制限があります。 PubsubにはETA機能はありません。私

    1

    1答えて

    長時間実行されているタスクを実行するためにGoogleのクラウドタスクキューを使用しています。 すべてのタスクが完了したら、私は何らかの通知を送ろうと思っていました。 私は私のスレッドで保留中のタスクの数を取得するためのコードの下に使用しています QueueStatistics統計= taskQueue.fetchStatistics(); stats.getNumTasks(); ここでは、ge

    0

    1答えて

    私のAPIでは、プロセス/レポートを実行している場所がいくつかあり、タイムアウトを起こしているか、単に時間がかかりすぎています。私は、これらのジョブを待ち行列に遅らせ、代わりに私の応答でキーを返したいと思います。フロントエンドはそのキーを使用してサービスにpingを実行し、キュー内の特定のジョブのステータスを判断します。このようにして、私たちは2分〜3分かけてアヤックスを掛けることはありません。た

    6

    2答えて

    RabbitMQのようなメッセージブローカーは、異なる言語/プラットフォームで書かれたさまざまなアプリケーションが互いに通信することを容易にします。セロリはメッセージブローカーとしてRabbitMQを使うことができるので、たとえプロデューサーがPythonで書かれていなくても、どのアプリケーションからでもタスクをCeleryにキューイングできます。 今、私はC#で書かれたアプリケーションからRab

    1

    1答えて

    私は現在、appengine上で動作するアプリケーションを持っていますが、遅延ライブラリを使用していくつかのジョブを実行しています。これらのタスクのほとんどは、Datastoreにクエリを実行してドキュメントを取得し、インデックスにエンティティを格納します(Search API)。これらのテーブルのいくつかは毎月置き換えられ、これらのタスクをすべてのエンティティ(4〜5M)で実行する必要があります