小编Adr*_*tin的帖子

为什么我们需要气流钩?

Doc 说:

Hooks 是外部平台和数据库的接口,如 Hive、S3、MySQL、Postgres、HDFS 和 Pig。Hooks 在可能的情况下实现一个公共接口,并充当操作符的构建块。参考

但是我们为什么需要它们?

我想从一个 Postgres 数据库中选择数据,然后存储到另一个。例如,我可以在由 python 操作员运行的 python 脚本中使用 psycopg2 驱动程序,或者气流出于某种原因应该知道我在脚本中到底在做什么,所以,我需要使用 PostgresHook 而不仅仅是 psycopg2 驱动程序?

python database airflow

9
推荐指数
2
解决办法
1169
查看次数

气流 - 如何将任务日志发送到弹性搜索?

我应该如何配置或从airflow 1.9发送任务日志到弹性搜索?我在当前的git存储库中找到了配置模板,但不确定是否可以在v 1.9中完成

elasticsearch airflow

8
推荐指数
1
解决办法
2527
查看次数

标签 统计

airflow ×2

database ×1

elasticsearch ×1

python ×1