问题标签 [wso2sp]

在 WSO2SP 中有一种方法可以使用 CSV 文件来生成事件。例如 ReceiveEventsFromFile 示例。在此示例中，我可以将文件放入文件夹中，扩展程序将读取文件并产生事件。

当我定义输入流时，我想知道是否有一种方法可以获得原始文件（输入文件）名称作为参数，例如 INPUT_FILE_NAME

是否有实现类似于以下示例的功能。

我正在尝试从命令提示符运行一个 siddhi 应用程序。从命令提示符而不是使用编辑器运行应用程序的命令是什么？

WSO2 SP 4.3.0 似乎不适用于大于 1024 个字符的 JSON 事件。有什么限制吗？

我正在使用 WSO2 流处理器版本 4.3.0。我有一个使用带有 JSON 映射的 HTTP 源部署的 Shiddi 应用程序。只要 JSON 事件少于 1024 个字符，一切正常。如果 JSON 的长度超过 1024 个字符，那么看起来 SP 正在将消息拆分为几个不同的事件，并且在尝试解析 JSON 内容时失败。

使用包含的示例“ReceiveHTTPInJsonFormatWithDefaultMapping”很容易重现。

-- 将 SweetProductionStream 中的数据传递到 LowProducitonAlertStream

然后尝试发送一个小事件：

这将起作用。然后发送一个长事件（超过 1024 个字符）

在日志中您可以看到：

我正在尝试使用以下代码从 Kafka 读取 JSON 数据：

但失败并出现以下错误：

[2019-03-27_11-39-32_103] 错误 {org.wso2.extension.siddhi.map.json.sourcemapper.JsonSourceMapper} - 流“myDataStream”没有名为“ABC”的属性，但接收到的事件 {” event":{"ABC":"1"}} 确实如此。因此丢弃该消息。检查 json 字符串的默认映射格式是否正确。

我试过添加属性

语法错误：

在流“myDataStream”中定义的“json”错误，未映射属性“json”

任何帮助将不胜感激。

我正在尝试动态创建多个流。例如。

的可能值type是['temperature','geolocation,'pressure']。所需的输出是每个用户一个流和每个用户类型组合一个流

1. 这可以在 wso2 中做到吗？

我尝试使用https://docs.wso2.com/display/SP4xx/Complex+JSON+Processing 进行复杂的 json 处理，但没有明确提及 @source 语法。

我正在尝试使用以下代码从 JSON 数据流生成 JSON 对象：

但是输出数据具有空值。请问代码有问题吗？

具有数据传递的输入流如下：

我正在尝试复制 wso2 流处理器文档中给出的“进行实时预测”教程，该教程根据温度和密度预测货物是否符合要求

我正在使用文档中给出的预训练 PMML 文件 (Sweet.pmml)。

这是 Siddhi 显示的错误，即使代码符合文档。

与输出'定义流PredictedSugarSyrupDataStream'（温度加倍，密度加倍，...）相同的不同定义已存在为'@sink（type =“log”，prefix =“预测的下一个糖浆运输：”）定义流PredictedSugarSyrupStream（nextTemperature double, ..., 决策 bool)'

顺便说一句，欢迎页面选项卡 ( PmmlModelProcessor )上有一个示例示例，它使用相同的语法运行良好。

我正在尝试复制 WSO2 流处理器文档中给出的“检测异常”教程。

我在调用异常值函数时遇到的错误是这样的。

我在这里遗漏了什么还是应该使用其他功能？

将哪些参数传递给预测函数？是否有任何文档可用于使用 siddhi 的 tensorflow 插件？

虽然样本中有一个 pbtxt 模型，但它本身非常模糊，没有关于使用什么来预测什么的背景。

有人可以帮我理解吗？

我正在运行一个 siddhi 应用程序，它监听事件并将它们写入远程机器上运行的 mongodb 实例。mongo db 实例具有基本的身份验证设置（用户名、密码）。我尝试连接到 mongodb 实例并将事件写入集合，在日志中我可以看到 wso2 可以连接到远程实例

当我尝试写入 mongodb 时，出现以下错误

我尝试在 siddhi 应用程序 @store() 中添加用户名和密码，并尝试在 /conf/worker/deployment.yaml 中添加数据源。在这两种情况下，我都会遇到相同的错误。

请协助。

问候和感谢，

柴塔尼亚·库马尔

数据科学家 - Koinearth。