У меня есть небольшая путаница по поводу потокового процессора. Раньше я использовал CEP, а теперь использую Stream Processor. если я не ошибаюсь, Data Analytics Server, CEP и Machine Learner объединены в Stream Processor, это правда? Потому...

У меня есть исходные данные из ActiveMQ, проблема в том, что эти данные не имеют фиксированной структуры, поэтому, когда я определяю поток, он выдает ошибку несовместимого типа данных, есть ли способ обусловить исходный поток каким-либо условием ?...

Следуя примерам, представленным в документации WSO2 SP 4.1.0, я пытаюсь запустить пример, в котором я читаю данные из файла csv, я предсказываю некоторый результат на основе данных и экспортирую предсказанный результат в файл csv. Пока чтение и...

во время тестирования производительности сервера потокового процессора wso2 я поместил более сотни файлов .siddhi в каталог развертывания. что приводит к проблеме "ко многим открытым файлам". Основные правила, которые у меня есть: все...

Я использую WSO2 Stream Processor 4.3.0 , я создал приложение siddhi и хочу развернуть и запустить это приложение на рабочем сервере в производственной среде. Я запустил рабочий профиль WSO2 SP с типом "wso2-sp" в deployment.yml файле. Как я...

Я установил WSO2 Api Manager на сервер и пытаюсь добавить аналитику. Проблема в том, что когда я меняю пароль администратора в WSO2 Api Manager, мой экземпляр Analytics сохраняет его старый пароль. Из-за этого Api Manager больше не может получить...

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

Можно ли использовать расширение javascript на сиддхи для запроса таблицы в памяти или другой базы данных? Моя функция должна идентифицировать все элементы в структуре данных b-tree. Спасибо.

WSO2 siddhi в настоящее время не имеет расширения для Amazon DynamoDB Store. Есть ли возможность подключить DynamoDB как серверную часть хранилища для событий сиддхи?

Я пытаюсь создать несколько потоков динамически. Например. {'event_type': 'temperature', 'users' : ['john', 'gary'], 'data': {'type': 'temperature', 'DeviceID': 'bcd', 'temperature': '45', 'timestamp': '2019-03-22T12:32:02.208223Z'...

Я пытаюсь создать объект JSON из потока данных JSON, используя нижеприведенный clode: @sink(type='log') define stream TempStream(designation object); from TestStream select json:setElement("{}", "$", json:getString(json,"$.DESIGNATION"),...

Я пытаюсь воспроизвести учебник «Создание прогнозов в реальном времени», приведенный в документации по потоковому процессору wso2, который предсказывает, будет ли груз соответствовать требованиям с учетом температуры и плотности. Я использую...

Я пытаюсь запустить RScriptSample, представленный в примерах, в потоковом процессоре. Я выполнил шаги, указанные здесь . Я установил R и rJava и соответственно установил R_HOME и JRI_HOME. @App:name("RScriptSample") @App:description('Use a...

Я изо всех сил пытаюсь понять этот запрос: from heartbeats#window.time(1 hour) insert expired events into delayedStream; from every e = heartbeats -> e2 = heartbeats[deviceId == e.deviceId] or expired = delayedStream[deviceId == e.deviceId]...

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