問題タブ [amazon-sqs]

次のコードを使用するSNSと、(キュー) で送信できSQSますが、Amazon の管理コンソールのようにプロトコルを選択できないようです

* キーはすべてランダムな文字列です

質問:どこでプロトコルを選択しますか?
このリンクはが定義されてsubscribe()いる場所であると言っていますが、上記の例ではそれをに送信しますprotocolSQS

Web クラスター環境で (特定の日時に 1 回だけ) タスクを確実に実行する方法を探しています。たとえば、最初の登録から 7 日後にユーザーにメール リマインダーを送信するなどです。cron/django-cron/django-chronograph などを使用してそれを達成する方法を認識していますが、これまでに見つけたものはすべて、単一サーバーのシナリオ用に設計されているようです。

同じジョブが複数のサーバーで実行された結果として重複したリマインダーを送信することを避けたいのですが、これまでのところ、Web クラスターでロック、有効期限のタイムアウトなどを使用して独自のデータベースベースのソリューションをロールアップすることが実際には唯一のオプションのようです。Web クラスター環境でうまく機能する既存のソリューションはありますか?

SQSを使用してS3にアップロードすると、プロセスのフォールトトレラントが向上しますか？

もしそうなら、私は構文に苦労していて、作成queueしてからS3にアップロードすることを組み合わせようとしています。ロジックが正しくない場合、にアップロードするために
使用するシステムをどのように設定しますか？SQSS3

@Scheduleアノテーションを使用してcronのような方法でエンタープライズロジックを実行するEJBがあります。

JBoss7.1finalを使用しています。

問題は、このメソッドがAWS SQSサービスからのメッセージを消費していることです。そのAPIでは、一度に最大10個のメッセージをフェッチするという制限があります。これにより、多くのメッセージがSQSに追加されますが、十分な速度で消費されません。したがって、私が質問したいのは、プールを作成し、2つまたは3つのEJBがSQSからのメッセージを同時に処理する方法があるかどうかです。

コマンドライン経由で ec2 上の SQS を操作するにはどうすればよいですか? AWS 開発者ツールで SQS ツールが見つかりません。

自動スケーリング グループの一部である ec2 インスタンスで boto ライブラリを使用する python スクリプトがあります。スクリプトは SQS キューからのメッセージを処理します。

while ステートメントを使用する意味はありますか? count() は次のようにリアルタイムで更新されますか?

1. 他のインスタンスはメッセージをキューから取り出します (または、2 倍にするつもりですか)。
2. 新しいメッセージがキューに追加されます (または、見逃してしまいますか?)

キューが空であっても、このスクリプトがキューへの新しい追加を常にリッスンするようにするにはどうすればよいですか?

この質問Processing items in SQS queue with a php scriptでは、「sqs ruby​​ クライアント ライブラリには、キューを継続的にポーリングし、キューでメッセージを受信するとそれをブロックに渡すメソッド「poll」がある」と述べられています。Pythonに同等のものはありますか?

SNS を使用してスクリプトにメッセージ キューのステータスを通知することも提案されていますが、メトリクス アラームが十分に細かく設定されていないため、SNS を使用して応答システムを構成する方法がわかりません。

リクエスト キューとレスポンス キューがあります。リクエスト キューからメッセージを取り出して、レスポンス キューに入れたいと思います。リクエスト キューから取り出された同じメッセージがレスポンス キューに入れられたことを識別できるようにしたいと考えています。

私は GAE で Boto を使用しています。

まず、メッセージ ID は一定であると想定しました。そのため、リクエスト キューからメッセージを読み取り、同じメッセージ オブジェクトをレスポンス キューに追加し、ID をクエリしました。SQS が新しい ID を生成しました。

次に、メッセージの本文は json オブジェクトであるため、カスタム フィールド 'messageId' を追加し、独自の ID を生成してキューに格納しました。しかし、その後、キューから一度に 10 件のメッセージを読み取るという制限があることがわかりました。また、SQS は分散型であるため、メッセージが返される保証はありません。

PHPスクリプトを呼び出すMySQLトリガーを作成しようとしています。MySQLサーバーインスタンスをRDSで実行していて、phpスクリプトを使用してSQSメッセージングシステムにメッセージを送信したいと考えています。

1. PHPスクリプトはどこに保存しますか？
2. EC2インスタンスにPHPSDKfor SQSをインストールする必要がありますか？

ここで質問
がありまし たが、SQS の使用方法を理解するポイントがまだありません。誰かコードを手伝ってください。

質問: SQS 内の 1 つの場所は?
私はアマゾンのチュートリアルを読んだことがありますが、コンセプトは素敵に見えますが、物事の実用的な側面が欠けています.
たとえば、この図は素晴らしいです: http://awsmedia.s3.amazonaws.com/catalog/images/159-for-madhu.png
SQS の内部には何が入りますか? S3にアップロードする方法は理解できたが、SQS部分についてはまだグレー

次のシナリオがあります。

• 処理が必要なジョブの場合、ジョブの説明を含むメッセージが Amazon SQS メッセージキューに送信されます
• 私は仕事をしなければならないさまざまなプロセスを持っています

次の条件を満たす必要があります。

1. 1 つのプロセスがジョブを完了できなかった場合 (そのプロセスが実行されているサーバーがクラッシュしたなどの理由で)、他のプロセスがそのジョブを再び使用できるようにする必要があります。
2. 1 つのジョブが処理されている間、同じ説明を持つ他のジョブは、最初のジョブが終了するかタイムアウトになるまで待機する必要があります。
3. システムは、メッセージ キューの長さに応じて簡単に拡張できる必要があります。

(1) を保証するために、Amazon SQS キューが提供するメッセージ ロック機能を使用することを最初に考えましたが、(2) を保証するにはどうすればよいでしょうか? プロセスを職務記述書に割り当てることはオプションですが、(3) はより困難になります。