問題タブ [amazon-sqs]

Amazon SQL で Celery + Kombu を使用しています。目標は、特定の日時にすでにスケジュールされているタスクを削除できるようにすることです。私はもう試した

しかし、それは何も変わりませんでした。SQS トランスポートの取り消しは実装されていませんか? その背後に何らかの設計上の決定があるのでしょうか、それともコードの「DeleteMessage」行によって実装されるべき機能が欠けているだけなのでしょうか?

SQSに複数のメッセージがあります。次のコードは、数十が表示されている場合でも（飛行中ではない）、 常に1つだけを返します。setMaxNumberOfMessages一度に複数を消費できると思いました..これを誤解しましたか？

私はまた、そのような運なしでwithMaxNumberOfMessagesを使用してみました：

キューにメッセージがあることをどうやって知ることができますか？1つ以上？

上記は常に前に実行され、int>1である

ご入力いただきありがとうございます

認証を使用して SQS からメッセージを投稿および読み取ることができるプログラムを作成します。ここからドキュメントを読みました。リンク:クエリ リクエスト認証

指定されたキューにメッセージを投稿し、続いてドキュメントを送信するプロセスを正常に作成しました。しかし、キューからメッセージを受信しようとすると、常に 403 エラーが発生します。また、POST メソッドと GET メソッドでは署名文字列の規則が異なることがわかりました。

署名文字列は次のとおりです。

URLは

そして、常に 403 禁止エラーが発生します。

どうすれば対処できるか教えてくれる人はいますか？どうもありがとう

メッセージを「既読」としてカウントしたくありませんが、キューに何が入っているかを知りたいです。ドキュメント:

http://boto.s3.amazonaws.com/ref/sqs.html#module-boto.sqs

何がメッセージを吸収し、何が吸収しないかについては、あまり単純ではありません。ダンプメッセージは近いようですが、ファイルではなくメモリでこれを行いたいと思います。

よくある質問:

http://aws.amazon.com/articles/1343#12

大ざっぱな解決策があります：

メッセージを確認するにはどうすればよいですか?

バージョン 2008-01-01 では、PeekMessage アクションが Amazon SQS から削除されました。この機能は、主に小規模なシステムをデバッグするために使用されました。具体的には、メッセージがキューに正常に送信されたか、キューから削除されたことを確認するために使用されました。バージョン 2008-01-01 でこれを行うには、メッセージ ID とメッセージの受信ハンドルをログに記録し、それらを関連付けて、メッセージがいつ受信され削除されたかを確認します。

これで運が良かった人はいますか？これは非常に基本的なキュー機能のように思えますが、これを行うクリーンな方法がなかったらショックです。

私は、botoを使用してSQSでメッセージを渡すことによってワークフローが管理されるアプリケーションに取り組んでいます。

SQSキューは徐々に大きくなっており、含まれているはずの要素の数を確認する方法がありません。

これで、キューを定期的にポーリングし、固定サイズの要素セットがあるかどうかを確認するデーモンができました。たとえば、次の「キュー」について考えてみます。

ここで、ある時点で「msg1_comp1」、「msg2_comp1」、「msg3_comp1」が一緒にキューにあるかどうかを確認したいのですが、キューのサイズがわかりません。

APIを調べた後、キュー内の要素を1つだけ取得するか、固定数の要素を取得できるようですが、すべてではありません。

回答で提案されている提案は、たとえば、何も返されないまでループで10個のメッセージを取得することですが、SQSのメッセージには可視性タイムアウトがあります。つまり、キューから要素をポーリングしても、実際には削除されません。それらは短期間しか見えなくなります。

キューにあるすべてのメッセージを、いくつあるかを知らなくても取得する簡単な方法はありますか？

AWS エンドポイントに送信された削除リクエストが 200 レスポンスで返されても、SQS キューに小さなメッセージ セットがあり、それらは削除されません。メッセージはアプリケーションによって正常に処理され、削除要求も正常に送信されます。

Java AWS SDK 1.3.6 を使用しています。

他の誰かがこの問題を経験しましたか?

タスクが利用可能になるまで、Google AppEngine プル タスク キューでブロックできますか? または、タスクが使用可能になるまで空のキューをポーリングする必要がありますか?

CI サーバーで SQS キューを使用して電子メールを送信したいと考えています。適切なタイミングで、サーバーは、送信される電子メールのすべての詳細を含むメッセージをこのキューに入れます。次に、このキューをリッスンしているデーモンは、新しいメッセージがあることに気づき、キューから取り出して正しいことを行い、実際に電子メールを送信します。

私の質問 - サーバーに "send_email" キュー インスタンスを 1 つだけ持たせ、常にそれを使用したいと考えています。では、メイン コントローラーの _construct() でキューを作成しますか? このように、一度だけ作成されますか？私はこれについて正しい方法で考えていますか？

ありがとう！

ミズ

Amazon の AWS が「あなたが提供した X509 証明書は私たちの記録に存在しません」と私に言う理由を誰かが知っているかどうか疑問に思っています。

これが私が使用しているコードです...

これが私が得る応答です...

config.inc.php 内で使用している CFCredentials 配列は次のとおりです...

もしそれがFIFOアクセスのようなものを提供するなら、Amazon SQSを使うのが好きだっただろうが、シーケンスは完全にランダムに見える。

クラウドサービスとしてのFIFOキューイングにSQSの高可用性を提供するものはありますか？

それがあまりにも多くを求めている場合-EC2で上記の要件を備えたものをまとめる最も簡単な方法は何でしょうか？または、言い換えると、EC2で機能する最も簡単な高可用性キューイングソリューションは何ですか？

あなたの洞察に感謝します！