"""Triggering ddex-ingester-register-delivery-to-ingest lambda.""" import json from time import sleep from boto3 import client as boto_client LAMBDA_NAME = 'ddex-ingester-register-delivery-to-ingest-qa' S3_BUCKET_NAME = 'qa-ddex-ingester' ddex_s3_keys = [ ] def main(): for s3_key in ddex_s3_keys: lambda_payload = { 'detail': { 'requestParameters': { 'bucketName': S3_BUCKET_NAME, 'key': s3_key, 'ddex_provider': 'SME_ANALYTICS_PROVIDER' }} } aws_lambda_client = boto_client('lambda', region_name='us-east-1') aws_lambda_client.invoke( FunctionName=LAMBDA_NAME, InvocationType='Event', Payload=bytes(json.dumps(lambda_payload), 'utf-8'), ) print(f'Invoked {LAMBDA_NAME}.') print(f'Lambda payload : {lambda_payload}. ') sleep(3) if __name__ == '__main__': main()