Facebook Ads To GCS Operators

Prerequisite Tasks

FacebookAdsReportToGcsOperator

Use the FacebookAdsReportToGcsOperator to execute a Facebook ads report fetch and load to GCS.

airflow/providers/google/cloud/example_dags/example_facebook_ads_to_gcs.pyView Source

    run_operator = FacebookAdsReportToGcsOperator(
        task_id='run_fetch_data',
        start_date=days_ago(2),
        owner='airflow',
        bucket_name=GCS_BUCKET,
        params=PARAMS,
        fields=FIELDS,
        gcp_conn_id=GCS_CONN_ID,
        object_name=GCS_OBJ_PATH,
    )

Was this entry helpful?