cosmos-db-migration-utility/src/lambda/batch-request-reader/lambda_function.py [37:47]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    return value

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/gap-watch-request-reader/lambda_function.py [42:52]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    return value

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)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -