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

Question

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

Answer 1

可以，您可以使用内存源和接收器在两个不同的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);

以上内容来自特定主题