【Laravel】【AWS SQS】キューに直接追加したメッセージを処理する方法はありますか？

Question

Laravelでジョブを作れば、キューへメッセージを送る処理と実行する処理を自動化出来る事は理解しております。
ジョブ機能を介さずに追加されたメッセージをLaravelで処理する方法はあるのでしょうか？

ご教示いただきたい事

最初に記載した内容と重複しますが、
Laravelのジョブ以外で追加したのメッセージを取得して、Laravelのジョブようにメッセージを解析して処理する方法は無いでしょうか？

想定している仕様

RDS（MySQL）とDynamoDBの同期をしたいと考えています。
DynamoDBのデータを取得して、アプリケーション側で処理をしてRDSに書き込みをしたいです。
そのために、下記の流れでデータを登録したいと考えています。

1. DynamoDBでレコードを追加したタイミング（dynamodb streams）をトリガーにLambdaの関数を実行
2. AmazonSQSのキューにメッセージを追加
3. 定期的にキューを監視し、追加されていればRDSに書き込み。

また、本件とは別に複数ジョブは動いていますので、
SQSにはLaravelから送られたメッセージが保管されています。

状況

下記は実現できる状態です。

• LambdaからAmazon SQSにメッセージを追加
• LaravelからRDSへの書き込み処理

Laravelから独自に追加したメッセージ取得、解析して、ジョブ（もしくは、独自の処理）を実行する方法がわからない状態です。

試した事、調べた事

Lambdaから直接、RDSへの書き込む。

LambdaでRDSを連携する場合、コネクション上限に達してしまう場合があるため現実的では無い。

スケジュール（Cron）でDynamoDBを監視して同期する処理を作る

RDSのDBに都度未同期のレコードがあるか検索する必要があるため、クエリの実行回数が多くなってしまいDBが重くなってしまいます。

Answer 1

以下のような方法はどうでしょうか。

• LambdaからAmazon SQSに追加するメッセージは、LaravelがJobをdispatchしたときにAmazon SQSに追加されるメッセージを真似る。
• そのメッセージをLaravelのキューワーカで処理させる。

（Amazon SQSの経験が無く思いつきで書きましたので自信無いです。的外れなことを書いていたらすみません）

Comments

[hasshy]

ご回答ありがとうございます。
既存の処理部分を解析して真似るのですね。
難しそうですね…。