Ошибка подключения GCP Composer (Airflow) к GCP PubSub. ⇐ Python

[Anonymous]

Я пытаюсь подписаться на GCP PubSub, чтобы получать сообщения от GCP Composer, но получил следующую ошибку:

Код: Выделить всё

airflow.exceptions.AirflowException: The conn_id `google_cloud_default` isn't defined

Мой код DAG следующий:

Код: Выделить всё

subscribe_pubsub_task = PubSubPullSensor(
task_id="subscribe_pubsub",
project_id=GCP_REPORTING_ID,
subscription=PUBSUB_SUBSCRIPTION,
ack_messages=True,
deferrable=True,
)

Я просмотрел документацию Airflow: https://airflow.apache.org/docs/apache- ... ogle/cloud /sensors/pubsub/index.html
Как получить идентификатор соединения с помощью учетной записи службы GCP для аутентификации?

Подробнее здесь: https://stackoverflow.com/questions/792 ... gcp-pubsub