Periodically ingest incremental updates (inserts / deletes) into BigQuery using Cloud Composer / Airflow orchestration workflow
bigqueryairflowgooglecomposercloudgcpoperatordataflowingestionperiodicdagchange-dataincerementalmerge-querybigqueryoperatordataflowtemplateoperator
-
Updated
Dec 12, 2019 - Python