Essayer de créer un modèle de formation de cloud avec SNS et SQS fonctionne, mais les messages n'arrivent jamais

Question

Après avoir parcouru la documentation, j'ai écrit le modèle de formation de cloud suivant pour créer un sujet SNS, un sujet SQS et abonner le sujet à la file d'attente SQS :

{
    "AWSTemplateFormatVersion": "2010-09-09",

    "Description": "Creates the SNS topic, SQS queue and instance that will service the custom resources queue",

    "Parameters": {
        "Environment": {
            "Description": "Environment in which to manage queues",
            "Type": "String",
            "Default": "qa",
            "AllowedValues": [ "development", "qa", "staging", "production"]
        },    
        "EmailAddress": {
            "Description": "Email to where notifications will be sent",
            "Type": "String",
            "Default": "example@email.com"
        }
    },

    "Resources": {
        "CustomResourcesQueue": {
            "Type": "AWS::SQS::Queue",
            "Properties": {
                "ReceiveMessageWaitTimeSeconds": 20,
                "VisibilityTimeout": 60,
                "QueueName": {
                    "Fn::Join": ["-", ["cloud_formation_custom_resources", {
                        "Ref": "Environment"
                    }]]
                }
            }
        },
        "CustomResourcesTopic": {
            "Type": "AWS::SNS::Topic",
            "Properties": {
                "Subscription": [
                    {
                        "Endpoint": {
                            "Ref": "EmailAddress"
                        },
                        "Protocol": "email"
                    },
                    {
                        "Endpoint": {
                            "Fn::GetAtt": ["CustomResourcesQueue", "Arn"]
                        },
                        "Protocol": "sqs"
                    }
                ]
            }
        },
        "SNSToSQSPolicy": {
            "Type": "AWS::SQS::QueuePolicy",
            "Properties": {
                "PolicyDocument": {
                    "Id": "PushMessageToSQSPolicy",
                    "Version": "2012-10-17",
                    "Statement": [
                        {
                            "Sid": "allow-sns-to-send-message-to-sqs",
                            "Effect": "Allow",
                            "Action": [ "sqs:*" ],
                            "Principal": {
                                "AWS": "*"
                            },
                            "Resource": {
                                "Ref": "CustomResourcesTopic"
                            },
                            "Condition": {
                                "StringEquals": {
                                    "aws:SourceArn": {
                                        "Ref": "CustomResourcesTopic"
                                    }
                                }
                            }
                        }
                    ]
                },
                "Queues": [
                    {
                        "Ref": "CustomResourcesQueue"
                    }
                ]
            }
        }
    }
}

La formation de cloud est créée avec succès, mais chaque fois que je publie un message sur le sujet SNS, je ne reçois que l'e-mail, le message n'arrive jamais dans la file d'attente SQS.

Est-ce que j'ai raté quelque chose dans la politique ici ?Existe-t-il un autre moyen d'utiliser les formations cloud pour lier SNS et SQS ?

Answer 1

Quelques éléments qui pourraient aider :

• J'ai "Resource": "*" dans ma politique de file d'attente.
• J'ai ArnEquals au lieu de StringEquals sur le Condition (mais je suppose que cela n'a pas d'importance).
• Vous devriez pouvoir vous en sortir en autorisant simplement "Action": ["sqs:SendMessage"].

Answer 2

"Resource": {
   "Ref": "CustomResourcesTopic"
 },

C'est incorrect, car ici vous devez utiliser la file d'attente Arn

"Resource": {
          "Fn::GetAtt": [
            "CustomResourcesQueue",
            "Arn"
          ]
        },

Et ce code aussi, je pense qu'il est faux

"Condition": {
     "StringEquals": {
          "aws:SourceArn": {
                "Ref": "CustomResourcesTopic"
               }
           }
      }

Parce que vous devriez utiliser de Topic Arn et utiliser "Ref": "CustomResourcesTopic" vous obtiendrez le TopicName

Alors il sera

"Condition": {
         "StringEquals": {
              "aws:SourceArn": "arn:aws:sns:{REGION}:{ACCOUNT_ID}:{TOPIC_NAME}"
               }
          }