Я слежу за этим https://github.com/teamclairvoyant/airflow-rest-api-plugin Репозиторий для работы с Airflow Dags. , Он содержит конечные точки API для приостановки / отмены / List_all / запуска DAG. Всякий раз, когда мы запускаем конечную точку API, мы получаем ответ в формате JSON. Я не получаю никаких предупреждений при запуске конечных точек API Pause / Unpause / List_all, но при запуске конечной точки триггера появляется предупреждение.
JSON ответ при вызове PAUSE конечной точки API.
{"airflow_cmd":"airflow pause airflow_sample",
"arguments":{
"api":"pause",
"dag_id":"airflow_sample"},
"call_time":"Wed, 05 Feb 2020 12:27:28 GMT",
"http_response_code":200,
"output":{
"stderr":"",
"stdin":"",
"stdout":"Dag: airflow_sample, paused: True\n"},
"post_arguments":{},
"response_time":"Wed, 05 Feb 2020 12:33:45 GMT",
"status":"OK"}
JSON ответ при вызове API TRIGGER :
{"airflow_cmd":"airflow trigger_dag airflow_sample",
"arguments":{
"api":"trigger_dag",
"dag_id":"airflow_sample"},
"call_time":"Wed, 05 Feb 2020 12:27:28 GMT",
"http_response_code":200,
"output":{
"stderr":"/home/bhanuprakash/.local/lib/python3.6/site-packages/pymysql/cursors.py:170: Warning: (1300, \"Invalid utf8mb4 character string: '800495'\")\n result = self._query(query)\n",
"stdin":"",
"stdout":""},
"post_arguments":{},
"response_time":"Wed, 05 Feb 2020 12:34:23 GMT",
"status":"OK"}
Как ясно видно при вызове конечной точки API триггера, я получаю STDERR . Это как-то связано с MySQL? Я в замешательстве.
PS: Это было предупреждение, но не ошибка. Влияет ли это на Результат?