cosmos-db-migration-utility/src/lambda/app-request-reader/lambda_function.py [14:22]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
def send_sqs_message(queue_name, payload, delay=0):
    data = json.dumps(payload)
    logger.info("Starting to send SQS requests to queue: %s. Payload: %s", queue_name, data)
    sqs_client = boto3.client('sqs')
    queue = sqs_client.get_queue_url(QueueName=queue_name)
    response = sqs_client.send_message(
        QueueUrl= queue['QueueUrl'], MessageBody=data, DelaySeconds=delay)
    logger.info("Successfully completed sending SQS requests to queue: %s. Response: %s",
        queue_name, response)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



cosmos-db-migration-utility/src/lambda/batch-request-reader/lambda_function.py [39:47]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
def send_sqs_message(queue_name, payload, delay=0):
    data = json.dumps(payload)
    logger.info("Starting to send SQS requests to queue: %s. Payload: %s", queue_name, data)
    sqs_client = boto3.client('sqs')
    queue = sqs_client.get_queue_url(QueueName=queue_name)
    response = sqs_client.send_message(
        QueueUrl= queue['QueueUrl'], MessageBody=data, DelaySeconds=delay)
    logger.info("Successfully completed sending SQS requests to queue: %s. Response: %s",
        queue_name, response)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -