ekuiper Problem of join stream and table from the same topic

Problem of join stream and table from the same topic

Open 1250526189 opened this issue 3 years ago • 0 comments

使用table做数据拼接

需求描述

数据初次发送为全量数据，之后发送局部数据，通过ekuiper对局部数据进行拼接，合并为全量数据后再发送给数据库

问题描述

创建一个流和一个表都订阅来自一个mqtt的topic，利用表中存储的全量数据对流中的数据进行拼接，有时能拼接成功，有时只能拼接一次。ekuiper使用的镜像为lfedge/ekuiper:1.6.0-slim

复现步骤

流demo和表demo_table定义主题device/demo，创建规则demo_test，进行数据拼接，发送到mqtt

sql语句

SELECT * FROM demo LEFT JOIN demo_table

测试数据

{
  "table":"control",
  "press":100,
  "height":100,
  "factory":"test",
  "area":"test"
}

{
  "table":"alarmtest",
  "LinkStatus": "00000110",
  "MatchStatus": "00000110",
  "UploadInterval": 30,
  "Vendor": "test",
  "DeviceModel": "test",
  "DeviceType": "test",
  "DeviceVersion": "V1.0.0",
  "DeviceUuid": "0000-0001",
  "DeviceName": "test",
  "DeviceAlisa": "test",
  "Location": "test",
  "PortType": 1,
  "Baudrate": 233,
  "WordLength": 1,
  "Parity": 1,
  "StopBits": 1,
  "Valid": "true"
}