aws SQSを使用してSQSからのメッセージを5バッチで受信しようとしましたが、5つの異なる子プロセスを作成してそれぞれが同時に実行し、ジョブは親プロセスに戻り、親プロセスはaws SQSから別のジョブを呼び出すことができます。同様に、これは作る5つのジョブは現在サーバー上で実行されているsqs-consumer nodejsを使用したSQSキュー並列処理
書かれたコードは次のとおりです。のhandleMessage()関数でここ
const app = Consumer.create({
queueUrl: 'QUEUE_URL',
batchSize: 5,
region:"eu-west-1",
visibilityTimeout : 300,
handleMessage: (message, done) => {
for(var i in data.Messages)
{
console.log(JSON.parse(data.Messages[i].Body));
done();
}
},
sqs: new AWS.SQS()
});
app.on('error', (err) => {
console.log(err.message);
});
app.start();
メッセージごとに複数の子プロセスが作成され、その後、戻って報告することができますすることができますか親プロセスがaws SQSからの他のメッセージを呼び出すことができるように、1つの子プロセスが実行を終了したときに、1つの親プロセスに?別のラムダ/外部プロセスからここ
ここであなたの問題は何ですか?または、概念証明が有効かどうかを確認していますか? – Kannaiyan
私はhandleMessagefunction内に子と親を実装することを考えていません –
一度に5つに制限するのはなぜですか? – dashmug