def invoke_redshift_data_api_lambda()

in use-cases/lambda-chaining-with-redshift-data-api/scripts/LambdaRedshiftSetupObjects.py [0:0]

• 18 lines of code
• 1 McCabe index (conditional complexity)

def invoke_redshift_data_api_lambda(lambda_arn, redshift_cluster_id, redshift_database, redshift_user, sql_text, sns_topic_arn):
        client = boto3.client('lambda')
        lambda_payload = {
            "Input": {
                "redshift_cluster_id": redshift_cluster_id,
                "redshift_database": redshift_database,
                "redshift_user": redshift_user,
                "action": "run_sql",
                "sql_text": sql_text,
                "sns_topic_arn": sns_topic_arn
            }
        }
        response = client.invoke(
            FunctionName=lambda_arn,
            InvocationType='Event',
            Payload=json.dumps(lambda_payload)
        )
        return response