Как интегрировать существующую систему в WSO2 DAS

У нас есть большое количество алгоритмов, написанных на C++ и Java. Теперь мы хотим представить платформу WSO2 DAS. Где и как мы можем интегрировать эти алгоритмы с DAS?

Я должен объяснить больше информации: эти алгоритмы используют аналитику в реальном времени, но мы обнаружили, что DAS использует siddhi для аналитики в реальном времени и не предоставляет никакого интерфейса или API, которые мы могли бы использовать для этих алгоритмов.


wso2 complex-event-processing siddhi wso2-das
person yeahliu    schedule 24.01.2016    source источник

Ответы (1)


arrow_upward
1
arrow_downward

WSO2DAS состоит из приемников событий, в которые приложения Java и C++ могут передавать данные, используя несколько протоколов, таких как thrift, http, soap, mqtt, jms, kafka и т. д. [1]

Siddhi можно использовать как библиотеку Java в ваших приложениях, или же вы можете создать поток событий с потоками и приемниками в WSO2 DAS и добавить запросы Siddhi в план выполнения. Для получения более подробной информации см. документацию Siddhi [2]

[1] https://docs.wso2.com/display/DAS300/Configuring+Event+Receivers

[2] https://docs.wso2.com/display/CEP400/SiddhiQL+Guide+3.0

person Tharik Kanaka    schedule 25.01.2016
comment
Система алгоритмов содержит более 100 алгоритмов, большая часть алгоритмов написана на C++, сгенерированном движком scilab. Каждый алгоритм извлекает данные из другой системы и после обработки отправляет результат в систему хранения (которая просто записывает в БД). Наш клиент сгенерирует алгоритм самостоятельно и отправит нам файл пакета (например, zip) или развернет его в системе алгоритмов. Но развертывание системы алгоритмов ужасно, а отсутствие мониторинга, логирования стабильно. Поэтому мы хотим представить продукт WSO2 для решения нашей проблемы. - person yeahliu; 25.01.2016
comment
Мы не можем изменить код алгоритма, и мы не можем использовать сиддхи, чтобы переписать существующий алгоритм, но мы можем применить интерфейс ввода и вывода. Мы хотим, чтобы WSO2 помог нам управлять этим алгоритмом, чтобы мы могли управлять их циклом подъема, контролировать их обработку, отслеживать входные/выходные данные, даже запускать их по событию, отправленному из DAS и т. д. Спасибо за любую помощь. - person yeahliu; 25.01.2016
comment
В этом случае вам нужно использовать DAS для получения событий извне, а затем выполнять дальнейшую обработку, мониторинг, регистрацию и т. д. После этого DAS может публиковать данные в вашем алгоритмическом приложении, используя такой протокол, как thrift. Результаты алгоритма можно отправить обратно в DAS с помощью приемника событий DAS wso2. Здесь вам нужно использовать существующие алгоритмы и написать интерфейсное приложение для приема и публикации событий, используя такой протокол, как thrift. - person Tharik Kanaka; 25.01.2016