This plugin moves data from the Marketo API to S3 based on the specified object

This hook handles the authentication and request to Marketo. This extends the HttpHook.

Core Airflow S3Hook with the standard boto dependency.

This operator composes the logic for this plugin. It fetches the Marketo specified object and saves the result in a S3 Bucket, under a specified key, in njson format. The parameters it can accept include the following.

marketo_conn_id The Airflow connection id used to store the Marketo credentials. marketo_endpoint The endpoint to retreive data for. Possible values include: - activities - campaigns - leads - programs - lead_lists

• start_at The starting date parameter. Ignored by all endpoints but leads.
• end_at The ending date parameter. Ignored by all endpoints but leads.
• payload Payload variables -- all are optional
• output_format The output format of the data. Possible values include: - json - avro Defaults to json.
• s3_conn_id The Airflow connection id used to store the S3 credentials.
• s3_bucket The S3 bucket to be used to store the Marketo data.
• s3_key The S3 key to be used to store the Marketo data.