Cloud Composer 1 befindet sich im Modus nach der Wartung. 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.

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.