我正在运行一个siddhi应用程序，它监听事件并将它们写入远程机器上运行的mongodb实例。mongo数据库实例具有基本的身份验证设置(用户名、密码)。我尝试连接到mongodb实例并将事件写入集合，在日志中我能够看到wso2可以连接到远程实例[2019-05-1712:30:25,753]INFO{org.mongodb.driver.cluster}-Clustercreatedwithsettings{hosts=[10.x.x.xxx:27017],mode=SINGLE,requiredClusterType=UNKNOWN,serverSelectionTimeout='

我尝试在流(包含日期时间)和日期时间列上的存储mongodb表之间进行查询。definestreamTriggerStream(lastexecstring);@info(name='ExtractData')fromTriggerStreamaserightouterjoinOFFRELOGasoono.lastmodified>e.lastexecselectCLIC_OFFRELOG,lastmodifiedinsertintoRECO_TEST;我从这个查询中没有得到任何数据。有没有办法以timsstamp格式转换日期时间列？最好的问候，尼古拉斯 最

siddhi-base事件驱动：消耗、处理、发送的数据都视作一次事件流处理、复杂事件处理平台siddhiapplication是类似于sql的脚本。.siddhi脚本中分号表示一句结束。包括消费者(sources)、生产者(sinks)、流、查询、表和方法及其他必要的约定可以接受\发送给许多不同类型的事件输入\输出，如tcp,http,kafka,file等。可以接受并转化为不同的数据格式：json,text,xml,key-value处理事件并进行转化，分析过程：接受事件进行消费，将事件传递给相应的查询处理，根据逻辑形成新事件，将新事件发送给流StreamandQuerydefinestre

siddhi-base事件驱动：消耗、处理、发送的数据都视作一次事件流处理、复杂事件处理平台siddhiapplication是类似于sql的脚本。.siddhi脚本中分号表示一句结束。包括消费者(sources)、生产者(sinks)、流、查询、表和方法及其他必要的约定可以接受\发送给许多不同类型的事件输入\输出，如tcp,http,kafka,file等。可以接受并转化为不同的数据格式：json,text,xml,key-value处理事件并进行转化，分析过程：接受事件进行消费，将事件传递给相应的查询处理，根据逻辑形成新事件，将新事件发送给流StreamandQuerydefinestre