python - 如何将 databricks_operator XCOM 变量 run_id 和 run_page_url 传递到 python 脚本中
问题描述
我需要将 XCOM 变量run_id和run_page_url ( https://airflow.apache.org/docs/apache-airflow/1.10.12/_modules/airflow/contrib/operators/databricks_operator.html ) 传递给 python 脚本或 DAG 中的变量. 我读到我需要使用 xcom_pull,但没有找到任何示例。
解决方案
推荐阅读
- java - 自定义primaryStage标题:以图标为中心
- parsing - 为编译器实现特定解析规则的不同方法
- python - 如果数据框不为空,如何使用数据框添加列?
- spotfire - Spotfire 每小时平均价值
- r - 如何使用 visreg 和 ggplot2 更改轴标签
- ios - 将数据从firebase加载到集合单元格内的tableview
- asp.net-core - 试图用数据库优先的方法来围绕自定义身份表
- javascript - 如何将 1 添加到当前年份
- angularjs - 防止用户在多个下拉列表中选择相同的值
- python - 如何使用 StackingClassifier + Logistic Regression(二元分类)找到系数的特征名称