0

AWS SQSを使ったキューシステムを構築しています。
Elastic Beanstalk上にnode.jsで実装したキューワーカーを使用しています。

以下のような処理の流れを想定しております。
1.リクエストを受ける
2.キューにメッセージを入れる
3.処理(DBへの登録)が終わる
4.メッセージの削除

現状、メッセージを削除していないため、使用したメッセージが
DeadLetterQueueとして残ってしまっているので
この問題を解決したいです。

公式ドキュメント( http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SQS.html#deleteMessage-property )のdeleteMessageを使用すれば良いということはわかるのですが、
それを一連の流れにどう組み込むのかがわかっていないです。
ご回答、よろしくお願いします。

3
  • ワーカー上でReceiveMessage→何らかの処理→DeleteMessage というのが一般的な流れかと思いますが、それでは解決になりませんか?それともDead Letter Queueにたまったメッセージをどう処理するべきかという質問でしょうか。
    – take88
    Commented 2016年11月18日 10:35
  • >ワーカー上でReceiveMessage→何らかの処理→DeleteMessage というのが一般的な流れかと思いますが こちらでやってみます。ありがとうございます
    – shoya
    Commented 2016年11月23日 0:35
  • もし解決出来たのでしたら、ご自身で回答を書いて、それを承認してください。そうするとこの質問が解決済みとマークされます。
    – take88
    Commented 2016年11月28日 13:35

1 件の回答 1

-1

ちなみに、SQSのトリガーを使ってlambda起動すればメッセージの削除は不要になります。
多分料金も安いですし。
もちろんlambdaで処理できる内容(DB登録など)ならばですけど。

3

この質問に回答するには、ログインする必要があります。

求めていた回答ではありませんか? のタグが付いた他の質問を参照する。