Я использую Stream Processor для получения событий, и мне нужно знать, что есть способ проверить, что какое-то событие пришло в течение указанного времени в окне? Допустим, мы хотим проверить, приходило ли это событие каждые 5 минут. Если это не...

У меня есть входной поток как wso2event на wso2 SP, и он содержит метку времени и полезную нагрузку. Полезная нагрузка в формате xml. Как я могу разобрать эту полезную нагрузку на переменные? Я вижу этот документ...

Я пытаюсь перейти с WSO2 DAS на SP; который включает переписывание определения потока событий с помощью сценария Siddhi SQL. моя цель состоит в том, чтобы все изменения были ограничены в скрипте Siddhi SQL (таким образом, в SP). Я использую DAS...

Я пытаюсь подключить сервер mysql через приложение siddhi, и для настройки я перешел по приведенной ниже ссылке документации. https://docs.wso2.com/display/SP430/Integrating+Datastores Но когда я запускаю приложение сиддхи, я получаю следующую...

Я пытаюсь использовать один поток, обрабатывать входящий формат json и записывать в разные потоки на основе атрибута в событии. Например, если входной поток состоит из чего-то вроде этого: { "event_type" : "temperature", "json" : {...

Я пытаюсь воспроизвести руководство «Обнаружение аномалий», приведенное в документации по потоковому процессору WSO2. @App:name('SugarSyrupOutlierPredictionApp') @source(type='http', receiver.url='http://localhost:5007/SugarSyrupEP', @map(type =...

Я пытаюсь сохранить события, которые соответствуют некоторым фильтрам, в эластичный индекс, но когда я устанавливаю таблицу хранилища, он говорит, что не может создать индекс для этой таблицы. Я тестировал это в версиях продукта 4.3.0 и 4.4.0, но...

Я пытаюсь извлечь действительный json из текста с помощью Siddhi json Execution API. Я загрузил siddhi-execution-json-1.1.1.jar из магазина wso2 и следую примеру, упомянутому в документации. Но тот же синтаксис выше не выдает ошибку...