AWS SQSからメッセージを取得する のバックアップ(No.2) - 闘うITエンジニアの覚え書き

sqs_send_messages.py

# TODO

sqs_receive_messages.py

import boto3

client = boto3.client('sqs')

response = client.get_queue_url(
    QueueName='string',
    QueueOwnerAWSAccountId='string'
)

response = client.receive_message(
    QueueUrl='string',
    AttributeNames=[
        'All'|'Policy'|'VisibilityTimeout'|'MaximumMessageSize'|'MessageRetentionPeriod'|'ApproximateNumberOfMessages'|'ApproximateNumberOfMessagesNotVisible'|'CreatedTimestamp'|'LastModifiedTimestamp'|'QueueArn'|'ApproximateNumberOfMessagesDelayed'|'DelaySeconds'|'ReceiveMessageWaitTimeSeconds'|'RedrivePolicy'|'FifoQueue'|'ContentBasedDeduplication'|'KmsMasterKeyId'|'KmsDataKeyReusePeriodSeconds',
    ],
    MessageAttributeNames=[
        'string',
    ],
    MaxNumberOfMessages=123,
    VisibilityTimeout=123,
    WaitTimeSeconds=123,
    ReceiveRequestAttemptId='string'

sqs = boto3.resource('sqs')

queue = sqs.get_queue_by_name(

   QueueName='string',
   QueueOwnerAWSAccountId='string'

)

sqs = boto3.resource('sqs')
queue = sqs.Queue('url')

receive_messages

MaxNumberOfMessages