AWSStepFunctions如何从SQS接收消息？ _程序开发

AWSStepFunctions如何从SQS接收消息？

创始人

2024-09-27 14:01:06

0次

首先，你需要在 AWS Step Functions 控制台中创建一个新的状态机。

在 State Machine JSON 中，添加一个新的 Task。

{
  "Comment": "SQS Consumer",
  "StartAt": "ConsumeMessages",
  "States": {
    "ConsumeMessages": {
      "Type": "Task",
      "Resource": "arn:aws:states:::sqs:receiveMessage",
      "Parameters": {
        "QueueUrl.$": "$.queueUrl",
        "MaxNumberOfMessages": 1
      },
      "Next": "ProcessMessage"
    },
    "ProcessMessage": {
      "Type": "Task",
      "Resource": "arn:aws:lambda:us-west-2:111111111111:function:processMessage",
      "End": true
    }
  }
}

其中，资源 arn:aws:states:::sqs:receiveMessage 用于从 SQS 队列中接收消息。参数 QueueUrl 为 AWS Step Functions 参数，用于指定 SQS 队列的 URL。

接下来，需要创建一个 Lambda 函数（本例中命名为 processMessage），用于处理从 SQS 接收到的消息。下面是一个示例 Lambda 函数代码：

exports.handler = async (event) => {
  console.log('Received event:', JSON.stringify(event, null, 2));

  const records = event.Records;
  for (const record of records) {
    console.log('Processing message:', record.body);
  }

  return {};
};

最后，你可以使用 AWS SDK for JavaScript 连接到 AWS Step Functions 并启动状态机。下面是一个示例代码：

const AWS = require('aws-sdk');
const sf = new AWS.StepFunctions();

const params = {
  stateMachineArn: 'arn:aws:states:us-west-2:111111111111:stateMachine:MySQSStateMachine',
  input: JSON.stringify({
    "queueUrl": "https://sqs.us-west-2.amazonaws.com/111111

上一篇：AWSStepfunctions嵌入式工作流程似乎有2-3秒的开销。

下一篇：AWSStepFunctions如何定价Map状态？

AWSStepFunctions如何从SQS接收消息？

相关内容

热门资讯