Вызов облачной функции Google в Airflow DAG ⇐ Python

[Anonymous]

У меня есть работающая облачная функция Google, я пытаюсь вызвать ее из группы обеспечения доступности баз данных Airflow.

до сих пор я пробовал использовать SimpleHttpOperator :

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

MY_TASK_NAME = SimpleHttpOperator(
task_id= "MY_TASK_NAME",
method='POST',
http_conn_id='http_default',
endpoint='https://us-central1-myprojectname.cloudfunctions.net/MyFunctionName',
data=({"schema": schema, "table": table}),
headers={"Content-Type": "application/json"},
xcom_push=False
)

но копаясь в журналах, он говорит, что не может найти ресурс:


{base_task_runner.py:98} ИНФОРМАЦИЯ — Подзадача: Запрошенный URL-адрес /https://us-central1-myprojectname.cloud ... nctionName не найден на этом сервере. Это все, что мы знаем.


также я заметил, что на самом деле сообщения публикуются на https://www.google.com/ + URL-адрес, который я дал:

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

Sending 'POST' to url: https://www.google.com/https://us-central1-myprojectname.cloudfunctions.net/MyFunctionName

как правильно вызвать функцию?
Спасибо

Подробнее здесь: https://stackoverflow.com/questions/576 ... irflow-dag