如何通过 Airflow 中的 XComs 将参数从 PythonOperator 传递到 HttpSensor？

Question

我想发送一个 HTTP 请求，其参数取决于依赖 Python 可调用的结果。我正在尝试为此目的使用 XComs。简化示例：

def get_index():
  return 0

get_index = PythonOperator(
  task_id='get_index',
  python_callable=get_index,
  dag=dag)

http_request = HttpSensor(
  task_id='send_http_request',
  http_conn_id=HTTP_HOST,
  endpoint=ENDPOINT,
  params={
    "index": "{{ ti.xcom_pull('get_index')  }}"
  },
  dag=dag)

get_index >> http_request

不幸的是，检查HTTP请求的选项后，我看到了宏没有正确和代替评价0，{{ ti.xcom_pull('get_index') }}被发送。可能出了什么问题？我应该使用HttpOperator代替HttpSensor吗？

Answer 1

我认为参数已被弃用，并且气流中的 jinja 模板引擎不会扫描这些参数。尝试使用 request_params 而不是 params （它是字符串键/值对的字典）。