問題タブ [job-queue]

システム内の各ジョブは特定のユーザー ID に属しており、複数のソースから rabbitmq に配置できます。私の要件:

• 任意の時点でユーザーごとに 1 つ以上のジョブを実行することはできません。
• 特定のユーザーのジョブが積み重なって、他のユーザーのジョブが遅延することはありません。
• 各ジョブは少なくとも 1 回実行する必要があります。各ジョブには最大再試行回数があり、失敗した場合は遅延してキューに再挿入 (またはおそらく遅延) されます。
• ジョブの順序 (ユーザーごと) を維持することは望ましいことですが、必須ではありません。
• ジョブは少なくとも 1 回実行する必要があるため、おそらく永続化する必要があります。ジョブの有効期限はありません。
• どのワーカーも、どのユーザーに対してもジョブを実行できる必要があります。

これらの要件により、個々のユーザーごとに 1 つのキューを維持することは理にかなっていると思います。また、すべてのユーザー キューを監視し、ジョブが現在どこにも実行されていないユーザーのジョブを実行するすべてのワーカーが必要です (つまり、ユーザーごとに 1 つのジョブしかありません)。

このソリューションは、クラスター設定で RabbitMQ を使用して機能しますか? キューの数が多くなるため、すべてのユーザー キューを監視する各ワーカーが大きなオーバーヘッドを引き起こすかどうかはわかりません。どんな助けでも大歓迎です。

Path の Android Priority Job Queueに似た iOS ジョブ キューを持っていて、コミュニティと共有してもかまわない人はいますか? 私は iOS を初めて使用するので、プラットフォーム自体がそのようなソリューションを提供しているかどうかはわかりません。Android にはそのようなものは存在しないため、Path が惜しみなく提供しているライブラリを使用する必要がありました。iOS 自体または Xcode にそのようなソリューション/API がある場合は、それを教えてください。そうでない場合は、あなたのものを共有してください。ありがとう。

基本的に、ネットワークがない場合でもユーザーがサーバーにデータを送信できるジョブ キューを探しています。つまり、ユーザーが iPhone の電源をオフにしても、キューはデータを保持します。その後、システムがネットワークを検出すると、データをサーバーにプッシュします。

SOにはすでに同様の質問があるので、詳細のためにそれを含めています: How to queue up data for server dispatch on android . 違いは、私の質問は iOS 用であり、彼らの質問は Android 用であることです。

使用事例

私のケースでは、ユーザーが地下鉄 (ネットワークなし) で電車に乗り込み、電子メールを送信することにしたとします。次に、アプリを閉じるか、電話の電源を切ります。それから 1 時間後、ユーザーが電話を再びオンにした後、ネットワークが検出されると、アプリはメールを送信します。

クライアントサーバーアプリケーションがあり、rxjava を使用してクライアントからのサーバーリクエストを実行しています。クライアントは一度に 1 つの要求のみを実行する必要があるため、トランポリン スケジューラに似たスレッド キュー スケジューラを使用するつもりです。

ここで、サーバー上の変更を監視するメカニズムを実装しようとしています。そのため、サーバーに何らかの変更が加えられて結果が返されるまでブロックする長期要求を送信します (ロング プル)。

この長いプル リクエストは、ジョブ キューがアイドル状態のときにのみ実行する必要があります。通常のリクエストがスケジュールされているときに監視リクエストを自動的に停止し、キューが空になったときに再び開始する方法を探しています。この動作を得るためにトランポリン スケジューラを変更することを考えましたが、これは一般的な問題であり、より簡単な解決策があるのではないかと感じています。

この種の構造を持つジョブキュー（Nodejs + Mongodb）を構築しています：

システムで 4 つのステータスを次のように定義しました: 新規、待機中、作業中、失敗、完了

要件: ステータスが「新規」のジョブ キューで最新のジョブを選択する必要があります。

現在、私はこれを使用してこれを行っています

これは、ジョブ ドキュメントが少ない場合にうまく機能します。しかし、文書番号が異なる状況がありました。50kまで上がります。次に、ロック期間 (mongostat を使用) が 100% を超えます (時には 200% に達します)。したがって、私のサーバーは、このようなシナリオでは新しいジョブを配信できません。

誰かがこのクエリのより効率的な方法を提案できますか??

前もって感謝します ：）

Path JobQueue ライブラリを使用して、データがサーバーに正常に送信されたことを知る方法はありますか? たとえば、AsyncTask を使用していた場合、onPostExecute がコールバック メソッドになります。

Path JobQueue ライブラリでは、私の理解では、onRun は AsynTask の doInBackground に似ています。onAdd は、データがローカル ディスクに永続化される場合に使用されます。助けてくれてありがとう。

Fiserv (以前の Open Solutions) DNA バンキング プラットフォームに詳しい人はいますか? ジョブの実行方法に問題があるため、ACH オリジネーションに関するセカンドオピニオンを探しています。

私たちが抱えている問題は、支払いがシステムに投稿されるタイミング、特にローンの支払いに関するものです。何が起こるかというと、元のファイルは支払い期日に Fed に送信されるように生成されますが、私たち側は、設定された日ではなく 1 日後に届きます。

ACHC/ACHD の設定を 2/1 と 1/1 の両方で実行してみましたが、両方の方法で同じ問題に遭遇したため、これが Fed Days に関連しているとは考えていません。 AH_ORIG および MM_SALOT/MM_IALOT ジョブが実行される順序。

MM_SALOT および MM_IALOT ジョブは、AH_ORIG ジョブが実行される前の夜に実行されることを知っています。AH_ORIG ジョブは、通常の ACH 例外処理中に午前中に実行されます。

また、ACH オリジネーション レポートで、トランザクションのローン側が XPMT として行われることにも気付きました。これは、別の機関で生成され、私たちに入金されるローンの支払いとほとんど同じです。私が持っている文書によると、私たちが開始したトランザクションの引き出し側は XWTH として表示され (実際にそうです)、ローンの割り当ては LPMT として表示されるべきです (そうではありません)。

私の質問は次のとおりです。私たちは週7日割り当てを処理し、ドキュメンタリーはACHCとACHDを1/1に設定する必要があると述べています. 2) AH_ORIG ジョブと MM_SALOT ジョブ、および MM_IALOT ジョブを実行する順序と実行時期は?

誰かがこれで私を助けることができれば、それは大歓迎です.

メッセージを消費者に発行する rabbitmq ラッパーを作成しましたが、これはうまく機能しています。

また、rabbitmq で (gearman のような) ワーク キューを作成して、長時間実行されるタスクをコンシューマーとコンシューマーに配布し、パブリッシャーに結果を通知することはできますか?

これには、パブリッシャーが消費者としても行動する必要があると思いますが、実装方法はわかりません。（私が間違っている場合は修正してください）。

または、rabbitmq はそのような場合のツールではありません。

ありがとう、

Parse の残忍なアキレス腱の 1 つは、ビデオをデータベースに保存できないことです (10 MB の制限は、ビデオの長さが 30 秒未満であることを意味します)。そのため、Parse を補足するために、Cloudinary Parse モジュールを使用しています。しかし今、私には問題があります。通常、Parse は最終的にデータをクラウドに保存することを処理し、ユーザーがオフライン中でもデータをアップロードできるようにします。などのジョブキューに依存することなく、Parse と Cloudinary でこれを達成する方法はありcompile 'com.path:android-priority-jobqueue:1.1.2'ますか?