QueueUrl=queue_url, AttributeNames=, MaxNumberOfMessages=10 :param sqs_client: boto3 sqs client to connect to AWS SQS :param queue_url: URL of the SQS queue to read. Note: this continues to generate messages until the queue is empty.Įvery message on the queue will be deleted. Parser.add_argument("-r", "-region", required=True, help="Region of the SQS queue, assume src and dest SQS"ĭef get_messages_from_queue(sqs_client, queue_url, max_nr_msg=0): "Use this to limit the message processed to avoid pending message from others") Help="Max number of messages to process, no limit if not specify." Parser.add_argument("-m", "-max-msg", required=False, type=int, Parser.add_argument("-d", "-dst-url", required=True, help="Queue to move messages to") Parser.add_argument("-s", "-src-url", required=True, help="Queue to read messages from") Usage: redrive_sqs_queue.py -src-url= -dst-url= -max-msg=ĭescription="Move all the messages from one SQS queue to another." Move all the messages from one SQS queue to another.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |