問題タブ [push-queue]

IronMQはプッシュ キューをサポートしていますが、サンプルの Heroku プッシュ キュー サブスクライバーは Web dyno として実装されています。Web リクエストを処理する Web dyno と、時間のかかるニーズを処理するワーカー dyno を使用するには、単一の Heroku プロジェクトが必要なので、これは厄介です。それが Heroku の設計方法です。

IronMQ APIは、パブリックにアクセス可能な URL を介してプッシュ キュー サブスクライバーにアクセスできる必要があることを示します。そのため、Web dyno が必要です。

単一の Heroku プロジェクト内で IronMQ プッシュ キューのパブリッシャーとサブスクライバーを取得する (クリーンな) 方法はありますか?

このようなものをサポートする別のキュー サービスはありますか (ロング ポーリング サブスクライバーでも機能します)。

私の目標は、X の試行後にプッシュ メッセージが失敗した場合に何らかの形で通知することです。

Iron.io プッシュ キュー ドキュメントの説明: エラー キュー http://dev.iron.io/mq/reference/push_queues/#error_queues

ドキュメントに従って、失敗したメッセージが指定された error_queue オプションでメッセージをトリガーするために、error_queue オプションを定義する必要があります。

IronQueue.php の push メソッドがオプション引数をサポートしていない場合、オプションを定義するにはどうすればよいですか。pushRaw がオプション引数をサポートしていることがわかります。

次のプッシュの例を pushRaw に変換するにはどうすればよいですか

プッシュ キューの失敗を検出する他の方法も歓迎します。

GAEのプッシュ キューによると、多数のタスク リクエスト ヘッダーがあります。

すでにエンキューされているタスクの数を確認する方法はありますか?

同じクラス内にあるカスタム ハンドラー メソッドを実行するために、タスクをキューにプッシュする次のようなコードを考えてみましょう。

$job->delete(); を追加する前に、これはうまくいきました。しかし、今ではエラーが発生しています:

Laravel 4.2 のドキュメントには、プッシュ キュー タスクがカスタム ハンドラ メソッドを指している場合、 $job->delete() を使用してキューからタスクを明示的に削除する必要がない理由が説明されていません。それでも、この種の実装は機能し、$job パラメーターがログに記録されると、それは false になります。

キューに非常に慣れていないので、優しくしてください。私の理解で$job->release()は、ジョブをキューに戻すことになっています。現在、以下のコードがありますが、キューを介してジョブを 1 回だけ実行します。最大 5 回まで実行できるようにする必要があり、再度失敗した場合は、削除するか何かを行います。

ワーカー：

押す！：

同期を使用してローカルでこれを実行しようとしています。queue:listen と queue:work を実行してから、プッシュ コードを実行してみました。1 エントリのみが記録されました。さらに情報が必要な場合はお知らせください。

Laravel が IronIO サーバーとの通信に失敗している間にプッシュ キューのタスクが失われないように、適切なアーキテクチャが必要です。

たとえば、途中で IronIO サービスの停止や DNS の問題が発生します。または、私たちの場合のように、iron-io/iron_mq パッケージが古くなり、プッシュが例外を発生させ始めたようです。

gecbla は例外をキャッチすることを提案していますが、そこからどのように進めますか?

フォールバック、例外処理アーキテクチャを実現する最善の方法は何ですか?

iron.io MQ プッシュ キューの使い方を学んでいます。Laravel php フレームワークでいくつかのメッセージをプッシュしていますが、すべてが機能します。ただし、私の知識をまとめるために、これらのメッセージの生の内容を確認したいと思います。私の iron.io アカウントでは、送信されたメッセージの総数を確認できますが、個々のメッセージとその内容を検査する場所が見つかりません。LaravelがIDやそのようなものを送信しているのだろうか..

Python Google App エンジン SDK と Django フレームワークを使用しています。私の場合、タスクキューはデッドライン超過エラーをスローしています

DeadlineExceededError: HTTP 要求への応答の全体的な期限を超えました。

ただし、基本スケーリングでタスク キューを使用し、基本スケーリングまたは手動スケーリングでドキュメントタスクに従って使用すると、最大 24 時間実行できます。

タスクはすべての MySQL DB 値を更新しているため、時間がかかります。

投稿リクエストを送信してタスクを開始する

このタスクは、dispatch.yaml によって基本スケーリング モジュールにディスパッチされます。

task モジュールには url のハンドラーがあります

デッドライン超過エラーなしでタスクをより長く実行する方法を誰か教えてください。

Google App Engine のドキュメントによると、タスクが Push-Queue に追加されると、Push-Queue は新しく追加されたタスクで指定されたハンドラ/URL への HTTP 呼び出しを開始します。

私の質問: Push-Queue によって開始された内部 HTTP 呼び出し (GAE を離れることのない HTTP 呼び出し) には、HTTP 呼び出し料金またはその他の料金が適用されますか?

私のタスク作成コード ( {root}.activities.service 内) は、おおよそ次のようになります。

コントローラー ( {root}.activities.controller 内)の受信エンドポイントは次のようになります。

Task が Push-Queue に追加されると、Push-Queue は「/activity」エンドポイントへの HTTP 呼び出しを行い、recordActivity() メソッドをトリガーします。