airflow.providers.segment.hooks.segment¶

连接到您的 Segment 账户，从中检索数据或向其写入数据。

注意：这个 hook 也依赖于 Segment analytics 包: https://github.com/segmentio/analytics-python

类¶

SegmentHook

创建到 Segment 的新连接，并允许您从中拉取数据或向其写入数据。

模块内容¶

class airflow.providers.segment.hooks.segment.SegmentHook(segment_conn_id='segment_default', segment_debug_mode=False, *args, **kwargs)[source]¶

基类: airflow.hooks.base.BaseHook

创建到 Segment 的新连接，并允许您从中拉取数据或向其写入数据。

然后，您可以将该 hook 与其他 Airflow 运算符一起使用，以便在 Segment 中移动数据或与 Segment 交互。

参数:

segment_conn_id (str) – 包含连接到 Segment 所需参数的连接名称。连接类型应为 json，并在 Extras 字段中包含一个 write_key 安全令牌。
segment_debug_mode (bool) – 确定 Segment 是否应在调试模式下运行。默认为 False

注意

您必须在 Extras 字段中包含一个 JSON 结构。我们需要用户的安全令牌来连接到 Segment。因此，我们在 Extras 字段中将其定义为：{“write_key”:”YOUR_SECURITY_TOKEN”}