跳转至

界面和操作 / 连接器

当用户需要访问外部数据库、第三方系统时,除了直接在代码中实现外,也可以使用 DataFlux Func 提供的「连接器」功能。

即使不使用连接器,用户也可以正常自行编写 Python 脚本访问外部数据库、第三方系统

连接器列表

在左侧边栏中选择「连接器」标签页,即可展示已经添加的所有连接器列表。

connector-aside.png

检测并添加本地 DataKit

DataFlux Func 启动时会自动检测本机及常见容器宿主机地址上的 DataKit,使用 IPv4 网络、HTTP 协议和端口 9529。检测成功后,会创建 ID 为 datakit 的 DataKit 连接器并置顶。

如果列表中没有 ID 为 datakit 的 DataKit 连接器,可以点击【检测并添加本地 DataKit】手工触发检测。例如,DataKit 在 DataFlux Func 启动后才安装或启动时,可通过该按钮重新检测。

已有 ID 为 datakit 的 DataKit 连接器会保留原有配置;该 ID 被其他类型连接器占用时,会提示占用情况。使用非默认端口、HTTPS 或其他服务器上的 DataKit 时,应手工创建连接器。

有关监听地址与连通性要求,请参考 连接并操作 DataKit

使用连接器

当正常添加连接器后,即可在脚本中使用连接器 ID 获取对应连接器的操作对象。

connector-id.png

假设存在一个 Redis 连接器,其 ID 指定为 redis,那么获取连接器操作对象的代码如下:

Python
1
2
3
redis = DFF.CONN('redis')
redis.query('SET', 'some_key', 'some_value')
print(redis.query('GET', 'some_key'))

也可以在连接器提示框中直接复制基本示例代码,减少键盘录入:

connector-code-example.png


参考文档

有关具体如何在脚本中使用连接器,可参考文档 脚本开发 / 连接器对象 DFF.CONN

部分连接器支持订阅消息并执行函数,可参考文档 脚本开发 / 连接器订阅