Step Functions Asynchronous Communication - Example 1

serverless.yml

service: example1

plugins:
  - serverless-step-functions
  - serverless-iam-roles-per-function

provider:
  name: aws
  runtime: nodejs10.x
  region: eu-west-1

functions:
  worker:
    handler: worker.handler
    iamRoleStatements:
      - Effect: "Allow"
        Action:
          - states:SendTaskSuccess
        Resource:
          Ref: ExampleStateMachine

stepFunctions:
  stateMachines:
    example:
      name: ExampleStateMachine
      definition:
        StartAt: PublishAndWait
        States:
          PublishAndWait:
            Type: Task
            Resource: arn:aws:states:::sqs:sendMessage.waitForTaskToken
            Parameters:
              QueueUrl:
                Ref: ExampleRequestQueue
              MessageBody:
                Input.$: "$"
                TaskToken.$: "$$.Task.Token"
            End: true

resources:
  Resources:
    ExampleRequestQueue:
      Type: AWS::SQS::Queue