Publica mensajes en un SNS tema de Amazon con Step Functions

Aprende a usar Step Functions para publicar mensajes en un SNS tema de Amazon. En esta página se enumeran las SNS API acciones de Amazon admitidas y se proporcionan ejemplos de Task estados para publicar un mensaje en AmazonSNS.

Step Functions puede controlar determinados AWS servicios directamente desde Amazon States Language (ASL). Para obtener más información, consulte Integración de otros servicios y Pasar parámetros a un servicio API en Step Functions.

En qué se diferencia la SNS integración optimizada de Amazon de la SNS AWS SDK integración de Amazon

No hay optimizaciones para los patrones de integración Respuesta de la solicitud o Cómo esperar una devolución de llamada con el token de tarea.

Amazon compatible SNSAPIs:

nota

Hay una cuota para el tamaño máximo de los datos de entrada o resultado para una tarea en Step Functions. Esto te limita a 256 KB de datos en una cadena codificada en UTF -8 cuando envíes o recibas datos de otro servicio. Consulte Cuotas relacionadas con ejecuciones de máquinas de estado.

• Publish

  • Sintaxis de la solicitud

  • Parámetros admitidos

    • Message

    • MessageAttributes

    • MessageStructure

    • PhoneNumber

    • Subject

    • TargetArn

    • TopicArn

  • Sintaxis de la respuesta

Los parámetros en Step Functions se expresan en PascalCase

Incluso si el servicio nativo API está encamelCase, por ejemplo, la API acciónstartSyncExecution, se especifican parámetros en PascalCase, como:StateMachineArn.

A continuación se incluye un Task estado que publica en un tema de Amazon Simple Notification Service (AmazonSNS).

{
 "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
    }
  }
}

Pasar valores dinámicos. Puede modificar el ejemplo anterior para transferir dinámicamente un atributo de esta JSON carga útil:

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

Anexa .$ al campo StringValue:

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

A continuación, se incluye un Task estado que se publica en un SNS tema de Amazon y, a continuación, espera a que se devuelva el token de la tarea. Consulte Cómo esperar una devolución de llamada con el token de tarea.

{  
   "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
      }
   }
}

Para obtener información sobre cómo configurar IAM los permisos cuando se utilizan Step Functions con otros AWS servicios, consulteCómo Step Functions genera IAM políticas para servicios integrados.