使用 Step Functions 调用 Amazon SNS - AWS Step Functions

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

使用 Step Functions 调用 Amazon SNS

Step Functions 可以直接从 Amazon States Language (ASL) 控制某些 AWS 服务。要了解更多信息，请参阅使用其他服务和将参数传递给服务 API。

优化的亚马逊 SNS 集成与亚马 AWS 逊 SNS 软件开发工具包集成有何不同

没有针对请求响应或等待具有任务令牌的回调集成模式的优化。

支持的 Amazon SNS API：

注意

在 Step Functions 中，任务的最大输入或结果数据大小有一个配额。在向另一个服务发送数据或从另一个服务接收数据时，数据大小不得超过 256 KB（UTF-8 编码字符串）。请参阅 与状态机执行相关的配额。

中的Step Functions参数表示为 PascalCase

即使原生服务 API 在 camelCase 中（例如 API 操作）startSyncExecution，您也可以在中指定参数 PascalCase，例如:。StateMachineArn

下面包括一个向 Amazon Simple Notification Service (Amazon SNS) 主题发布的任务状态。

{
 "StartAt": "Publish to SNS",
 "States": {
   "Publish to SNS": {
     "Type": "Task",
     "Resource": "arn:aws:states:::sns:publish",
     "Parameters": {
       "TopicArn": "arn:aws:sns:us-east-1:123456789012:myTopic",
       "Message.$": "$.input.message",
       "MessageAttributes": {
         "my_attribute_no_1": {
           "DataType": "String",
           "StringValue": "value of my_attribute_no_1"
         },
         "my_attribute_no_2": {
           "DataType": "String",
           "StringValue": "value of my_attribute_no_2"
         }
       }
     },
     "End": true
    }
  }
}

传递动态值。您可以修改上面的示例，以动态传递来自此 JSON 有效负载的属性：

{
"input": {
  "message": "Hello world"
},
"SNSDetails": {
  "attribute1": "some value",
  "attribute2": "some other value",
}
}

将 .$ 附加到 StringValue 字段：

"MessageAttributes": {
  "my_attribute_no_1": {
      "DataType": "String",
      "StringValue.$": "$.SNSDetails.attribute1"
  },
  "my_attribute_no_2": {
      "DataType": "String",
      "StringValue.$": "$.SNSDetails.attribute2"
  }

以下内容包括发布 Amazon SNS 主题，然后等待返回任务令牌的 Task 状态。请参阅 等待具有任务令牌的回调。

{  
   "StartAt":"Send message to SNS",
   "States":{  
      "Send message to SNS":{  
         "Type":"Task",
         "Resource":"arn:aws:states:::sns:publish.waitForTaskToken",
         "Parameters":{  
            "TopicArn":"arn:aws:sns:us-east-1:123456789012:myTopic",
            "Message":{  
               "Input.$":"$",
               "TaskToken.$":"$$.Task.Token"
            }
         },
         "End":true
      }
   }
}

有关在与其他 AWS 服务Step Functions一起使用时如何配置IAM权限的信息，请参阅集成服务的 IAM 策略。