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.

Implizit über die Airflow-Standardverbindung

Führen Sie eine Aufgabe aus, ohne die Airflow-Verbindung festzulegen. Die Standardverbindung wird verwendet.

Weitere Informationen

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

Airflow-Verbindungen verwalten

Codebeispiel

Python

Auf GitHub ansehen Feedback

task_default = bigquery.BigQueryInsertJobOperator(
    task_id='task_default_connection',
    configuration={
        "query": {
            "query": 'SELECT 1',
            "useLegacySql": False
        }
    }
)

Weitere Informationen

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