В настоящее время мы используем кинезис для получения данных о событиях реального времени в формате json и загрузки их в s3 и Redshift.Какова наилучшая практика для подключения AWS Kinesis с wso2cep
Для того чтобы онлайн-события включали сложные события на основе агрегации, мы планируем использовать wso2 cep, с Storm для масштабируемости.
Какова наилучшая практика здесь? Должен ли шторм быть связанным с кинезисом?
Когда вы используете WSO2 CEP с масштабированием Storm, вы должны отправлять события WSO2 CEP, которые будут публиковать события в Storm и возвращать результаты. В основном развертывание Storm будет прозрачным, и вы будете отправлять и получать события через CEP. AFAIU Вы можете отправлять события на WSO2 CEP с помощью желаемого метода через пользователя в Kinesis. CEP поддерживает множество receiver types.
Вы можете обратиться к this, чтобы узнать больше о архитектуре развертывания и конфигурациях. This Руководство объясняет, как создать план выполнения и развернуть в шторме. Чтобы попробовать функциональность, вы можете следовать образцу this.
С уважением