airflow.providers.google.cloud.example_dags.example_functions

Example Airflow DAG that displays interactions with Google Cloud Functions. It creates a function and then deletes it.

This DAG relies on the following OS environment variables https://airflow.apache.org/concepts.html#variables

  • GCP_PROJECT_ID - Google Cloud Project to use for the Cloud Function.

  • GCP_LOCATION - Google Cloud Functions region where the function should be created.

  • GCF_ENTRYPOINT - Name of the executable function in the source code.

  • and one of the below:

Module Contents

airflow.providers.google.cloud.example_dags.example_functions.GCP_PROJECT_ID[source]
airflow.providers.google.cloud.example_dags.example_functions.GCP_LOCATION[source]
airflow.providers.google.cloud.example_dags.example_functions.GCF_SHORT_FUNCTION_NAME[source]
airflow.providers.google.cloud.example_dags.example_functions.FUNCTION_NAME[source]
airflow.providers.google.cloud.example_dags.example_functions.GCF_SOURCE_ARCHIVE_URL[source]
airflow.providers.google.cloud.example_dags.example_functions.GCF_SOURCE_UPLOAD_URL[source]
airflow.providers.google.cloud.example_dags.example_functions.GCF_SOURCE_REPOSITORY[source]
airflow.providers.google.cloud.example_dags.example_functions.GCF_ZIP_PATH[source]
airflow.providers.google.cloud.example_dags.example_functions.GCF_ENTRYPOINT[source]
airflow.providers.google.cloud.example_dags.example_functions.GCF_RUNTIME = nodejs14[source]
airflow.providers.google.cloud.example_dags.example_functions.GCP_VALIDATE_BODY[source]
airflow.providers.google.cloud.example_dags.example_functions.body[source]
airflow.providers.google.cloud.example_dags.example_functions.default_args :Dict[str, Any][source]
airflow.providers.google.cloud.example_dags.example_functions.deploy_task[source]

Was this entry helpful?