def invoke_redshift_data_api_lambda()

in use-cases/aws-lambda-redshift-event-driven-etl/LambdaSetupRedshiftObjects.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": "execute_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