将 ThingsBoard 与 OCI 流处理服务集成

简介

ThingsBoard 是一个开源 IoT 平台，可用于数据收集、处理、可视化和设备管理。本教程将介绍将 ThingsBoard 与 Oracle Cloud Infrastructure (OCI) 流处理服务集成所需的步骤。这样，您可以将数据存储在数据库中、进行分析、使用函数来修改和处理此信息。

目标

从 OCI 中收集必要的信息。
在 ThingsBoard 规则链中配置 Kafka 节点。

先决条件

基本了解 OCI 流处理服务，Kafka。
了解 ThingsBoard 规则链。
能够创建和访问流处理资源的用户权限。
计算机上安装了 ThingsBoard。您可以在此处找到社区版的安装步骤。

任务 1：收集与 Kafka 服务器集成所需的 OCI 漫游参数

如果您尚未创建 OCI 流，您可以按照这些步骤，从控制台创建新流。
对于现有流，请注意以下信息：
- 打开导航菜单，然后单击 Analytics & AI 。
- 在消息传递下，单击流处理。
- 在流选项卡下，打开现有流并记下流名称，例如：thingsboard_stream
- 单击流池链接，例如：thingsboard_stream_pool
- 在左侧菜单上，转到 Kafka 连接设置，然后复制以下信息：
  - 引导服务器：例如 cell-1.streaming.eu-frankfurt-1.oci.oraclecloud.com：9092
  - SASL 连接字符串：例如，*org.apache.kafka.common.security.plain.PlainLoginModule required username=” /oracleidentitycloudservice//" password="AUTH_TOKEN"；*
  - Security Protocol（安全协议）：SASL_SSL
  - 安全机制： PLAIN
- 在屏幕右上角，单击配置文件图标。在用户配置文件下，单击 Auth 令牌，生成令牌并复制值：AUTH_TOKEN，例如： xmo？(cv<abcd...。。您还可以使用现有令牌。

任务 2：配置 Kafka 规则节点

Kafka 规则链

从操作面板中拖动 Kafka 规则节点。我们将使用任务 1 中记录的信息来配置 Kafka 规则。
- 名称：例如 - ThingsBoard2OCIStream
- 主题模式：“StreamName”，例如 thingsdemo-s0
- 引导服务器：“引导服务器”，例如 cell-1.streaming.eu-frankfurt-1.oci.oraclecloud.com：9092
- 其他属性：单击添加并添加以下键对：
  - security.protocol ：“安全协议”SASL_SSL
  - sasl.mechanism ：“安全机制”PLAIN
  - ssl.endpoint.identification.algorithm:https
  - sasl.jaas.config ：<SASL 连接字符串：>，例如 - *org.apache.kafka.common.security.plain.PlainLoginModule required username=” //" password="AUTH_TOKEN"；*（将 AUTH_TOKEN 替换为任务 1 中复制的值）

注意：

如果字符串 sasl.jaas.config 不起作用，租户中 Oracle Identity Cloud Service 可能存在问题，因此请尝试使用本地用户的相同内容。

可选：您还可以检查调试模式以进行故障排除。

更新所需值后，单击复选标记按钮以保存配置。

任务 3：配置规则链

规则链配置

在 save timeseries 和 kafka 块之间“拖动链接”，以便可以将保存的时间序列转发到 OCI 流。
输入链接标签的成功。
单击 "Checkmark" 按钮可保存配置。
登录到 OCI 控制台并检查流以确认流正在接收数据。单击加载消息。

在 OCI 流处理中收到信息后，您可以使用 OCI 服务连接器服务，例如将其传输到其他服务，例如 OCI 存储、OCI 函数等。

确认

Adina Nicolescu（高级云工程师），Guido Alejandro Ferreyra（首席云架构师）