x/opengeminiWrite组件：v0.24.0+ opengemini写客户端。把当前消息负荷写入 OpenGemini 服务器。

配置

该组件允许通关过server字段复用共享的连接客户端。参考组件连接复用 。

字段	类型	说明	默认值
server	string	opengemini服务地址，格式: 主机名:端口，多个服务器用逗号隔开	无
database	string	数据库，可以使用组件配置变量	无
username	string	用户名	无
password	string	密码	无
token	string	认证token,如果Token不为空，使用Token认证	无

写入格式

Json格式

消息负荷格式必须是Json格式：msg.DataType = types.JSON

写入格式支持多条或者单条，例如：

{
  "Fields": {
    "value": 98.6
  },
  "Measurement": "cpu_load",
  "Tags": {
    "host": "server01"
  },
  "Time": "2024-09-01T13:41:27.3142051+08:00"
}

[
  {
    "Fields": {
      "value": 98.6
    },
    "Measurement": "cpu_load",
    "Tags": {
      "host": "server01"
    },
    "Time": "2024-09-01T13:41:27.3142051+08:00"
  },
  {
    "Fields": {
      "value": 91.6
    },
    "Measurement": "cpu_load",
    "Tags": {
      "host": "server02"
    },
    "Time": "2024-09-01T13:41:27.3142051+08:00"
  }
]

Time：必须是RFC3339格式，例如：2024-09-01T13:41:27.3142051+08:00。如果不填，默认为当前时间戳。

Line Protocol格式

Line Protocol（行协议）格式参考文档Line Protocol (opens new window) 消息负荷格式必须是TEXT格式：msg.DataType = types.TEXT 写入格式支持多条或者单条，多条使用\n,例如：

cpu_load,host=server01 value=98.6 1693821027000000000
cpu_load,host=server02 value=91.6 1693821027000000000

时间戳必须为纳秒，例如：1693821027000000000，如果不填，默认为当前时间戳。

Relation Type

• Success: 执行成功，把消息发送到Success链
• Failure: 执行失败，把消息发送到Failure链

执行结果

无