[siddhi]如何在多个文件中使用 siddhi 流

Question

我在使用 siddhi 时遇到了一个问题，问题是我在一个 .siddhi 中有太多的流 file.The siddhql 看起来很糟糕而且很难维护。有谁知道如何将 siddhi 流放入不同的 siddhi 文件中？不同文件中的这些流仍然可以将信息发送到其他 file.Please 帮助中的流。感谢您的宝贵时间

Answer 1

是的，您可以使用 Inmemory source 和 sinks 在两个不同的 siddhi 文件之间发送事件，即两个不同的 siddhi 应用程序运行时， https://siddhi.io/en/v5.1/docs/api/latest/#inmemory-source

@sink(type='inMemory', topic='Stocks', @map(type='passThrough'))
define stream StocksStream (symbol string, price float, volume long);

以上发给具体话题

@source(type='inMemory', topic='Stocks', @map(type='passThrough'))
define stream StocksStream (symbol string, price float, volume long);

以上内容来自特定主题

[siddhi]如何在多个文件中使用 siddhi 流

[siddhi]How Can I use siddhi stream in multi files

siddhi