SQS get_queue_by_name не может найти очередь в AWS Lambda - PullRequest
Новая
       38

SQS get_queue_by_name не может найти очередь в AWS Lambda

0 голосов
/ 07 октября 2019

Я пытаюсь записать в очередь SQS из лямбды AWS, как показано ниже. 

sqs = boto3.resource(
        'sqs',
        region_name='us-east-1'
    )

def lambda_handler(event, context):
    queue_name = event["queue_name"]
    sqsQ = sqs.get_queue_by_name(QueueName=queue_name)
    msg_body = {
            "source": "some_source",
            "mse": 120
        }
    msg = sqsQ.send_message(MessageBody=json.dumps(msg_body), MessageGroupId="some_id", MessageDeduplicationId=str(uuid.uuid4()))

Но я получаю ошибку несуществования очереди 

"errorMessage": "An error occurred (AWS.SimpleQueueService.NonExistentQueue) when calling the GetQueueUrl operation: The specified queue does not exist or you do not have access to it.",
  "errorType": "QueueDoesNotExist",

Я убедился, что имя очереди правильное (копия вставлена) и это правильный регион.

Чего мне не хватает?

1 Ответ

1 голос
/ 07 октября 2019
  • Стоит проверить, что у Lambda есть следующие разрешения для управления сообщениями в очереди Amazon SQS. Добавьте их в роль выполнения вашей функции. sqs:ReceiveMessage, sqs:DeleteMessage, sqs:GetQueueAttributes. aws docs 
def get_msg_from_sqs():
    sqs_client = boto3.client('sqs')

    print("--- Getting message from SQS")
    response = sqs_client.receive_message(
        QueueUrl="https://sqs.eu-west-2.amazonaws.com/0000000000/manual_test_to_mesage_sender_queue",
        MaxNumberOfMessages=10,
        WaitTimeSeconds=10
    )

    print("--- Full Response:")
    print(response)

    messages = response.get('Messages')
    for message in messages:
        body = message.get('Body')
        json_body = json.loads(body)
        message = json_body.get('Message')
        json_msg = json.loads(message)

        print("--- Message:")
        print(json_msg.get('number'))
        print(json_msg.get('session_id'))
...