Cloud Composer 1 befindet sich im Nachwartungsmodus. Google veröffentlicht keine weiteren Updates für Cloud Composer 1, einschließlich neuer Versionen von Airflow, Fehlerkorrekturen und Sicherheitsupdates. Wir empfehlen, die Migration zu Cloud Composer 2 zu planen.

BigQuery-bq-Befehl mit dem BashOperator ausführen

Verwenden Sie den BashOperator in einem Apache Airflow-DAG, um den BigQuery-bq-Befehl aufzurufen.

Weitere Informationen

Eine ausführliche Dokumentation, die dieses Codebeispiel enthält, finden Sie hier:

DAGs (Workflows) schreiben

Codebeispiel

Python

Auf GitHub ansehen Feedback

from airflow.operators import bash
    # Create BigQuery output dataset.
    make_bq_dataset = bash.BashOperator(
        task_id='make_bq_dataset',
        # Executing 'bq' command requires Google Cloud SDK which comes
        # preinstalled in Cloud Composer.
        bash_command=f'bq ls {bq_dataset_name} || bq mk {bq_dataset_name}')

Weitere Informationen

Codebeispiele für andere Google Cloud-Produkte finden Sie im Google Cloud-Beispielbrowser.