Skip to content

Latest commit

 

History

History
 
 

cloud-composer-examples

Cloud Composer Examples:

This repo contains the following examples of using Cloud Composer, Google Cloud Platform's managed Apache Airflow service:

  1. Composer Dataflow Examples

    a. Simple Load DAG: provides a common pattern to automatically trigger, via Google Cloud Function, a Dataflow job when a file arrives in Google Cloud Storage, process the data and load it into BigQuery. Alt text

  2. Composer HTTP Example

    a. Ephemeral Dataproc Spark DAG: provides an example of triggering a DAG via HTTP POST to the Airflow API to create a Dataproc cluster, submit a Spark job, and import the newly enhanced GCS files into BigQuery. Alt text

Run Tests

Run this script to automate spin up / tear down of a lightweight airflow environment to run your tests.

./run_tests.sh