[アップデート] Amazon SNS でも AWS X-Ray のアクティブトレース統合機能が追加されていました

AWSTemplateFormatVersion: 2010-09-09
Transform: AWS::Serverless-2016-10-31
Description: '---'
Resources:
  Api:
    Type: AWS::Serverless::Api
    Properties:
      Name: !Sub
        - ${ResourceName} From Stack ${AWS::StackName}
        - ResourceName: Api
      StageName: Prod
      DefinitionBody:
        openapi: '3.0'
        info: {}
        paths:
          /:
            get:
              consumes:
              - "application/json"
              produces:
              - "application/json"
              responses:
                "200":
                  description: "200 response"
                  schema:
                    $ref: "#/definitions/Empty"
              x-amazon-apigateway-integration:
                responses:
                  default:
                    statusCode: "200"
                    responseTemplates:
                      application/json: "{\n  \"hoge\":\"iwasa\"\n}"
                requestTemplates:
                  application/json: "{\"statusCode\": 200}"
                passthroughBehavior: "when_no_match"
                type: "mock"
          /sns:
            post:
              produces:
                - application/json
              responses:
                '200':
                  description: 200 response
                  schema:
                    $ref: '#/definitions/Empty'
              parameters:
                - name: Message
                  in: query
                  required: true
                  type: string
                - name: topicArn
                  in: query
                  required: true
                  type: string
              x-amazon-apigateway-integration:
                credentials: !GetAtt ApiTopicSendMessageRole.Arn
                httpMethod: POST
                uri: arn:aws:apigateway:ap-northeast-1:sns:action/Publish
                responses:
                  default:
                    statusCode: '200'
                requestParameters:
                  integration.request.querystring.TopicArn: method.request.querystring.topicArn
                  integration.request.querystring.Message: method.request.querystring.Message
                passthroughBehavior: when_no_match
                type: aws
      EndpointConfiguration: REGIONAL
      TracingEnabled: true
  Topic:
    Type: AWS::SNS::Topic
    Connectors:
      sqsQueues:
        Properties:
          Destination:
            - Id: QueueC1
            - Id: QueueC2
          Permissions:
            - Write
    Properties:
      Subscription:
        - Endpoint: !GetAtt QueueC1.Arn
          Protocol: sqs
        - Endpoint: !GetAtt QueueC2.Arn
          Protocol: sqs
  ApiTopicSendMessageRole:
    Type: AWS::IAM::Role
    Properties:
      AssumeRolePolicyDocument:
        Statement:
          - Action:
              - sts:AssumeRole
            Effect: Allow
            Principal:
              Service:
                - apigateway.amazonaws.com
        Version: '2012-10-17'
      Path: /
      Policies:
        - PolicyDocument:
            Statement:
              - Action: sns:Publish
                Effect: Allow
                Resource: !Ref Topic
            Version: '2012-10-17'
          PolicyName: ApiTopicSendMessagePolicy
  QueueC1:
    Type: AWS::SQS::Queue
    Properties:
      MessageRetentionPeriod: 345600
  QueueC2:
    Type: AWS::SQS::Queue
    Properties:
      MessageRetentionPeriod: 345600
  Function1:
    Type: AWS::Serverless::Function
    Properties:
      Description: !Sub
        - Stack ${AWS::StackName} Function ${ResourceName}
        - ResourceName: Function1
      CodeUri: src/Function1
      Handler: handler.handler
      Runtime: python3.9
      MemorySize: 3008
      Timeout: 30
      Tracing: Active
      Events:
        QueueC1:
          Type: SQS
          Properties:
            Queue: !GetAtt QueueC1.Arn
            BatchSize: 1
  Function2:
    Type: AWS::Serverless::Function
    Properties:
      Description: !Sub
        - Stack ${AWS::StackName} Function ${ResourceName}
        - ResourceName: Function2
      CodeUri: src/Function2
      Handler: handler.handler
      Runtime: python3.9
      MemorySize: 3008
      Timeout: 30
      Tracing: Active
      Events:
        QueueC2:
          Type: SQS
          Properties:
            Queue: !GetAtt QueueC2.Arn
            BatchSize: 1