WSO2 CEP - Пользовательский адаптер приемника: форматы событий

Question

Я пытаюсь создать пользовательский адаптер приемника. Которая будет считываться из CSV-файла и передает события в поток. Насколько я понимаю, мы должны следить за любым стандартным форматом WSO2 (TEXT, XML или JSON), чтобы передавать данные в поток.

Проблема в том, что файлы CSV не соответствуют ни одному из стандартных форматов, указанных выше. Мы должны преобразовать значения csv в любой поддерживаемый формат в пользовательском адаптере. Согласно моему наблюдению, формат WSO2 TEXT не поддерживает запятую (,) в пределах строкового значения. Итак, я решил конвертировать CSV JSON.

Мои вопросы ниже:

1. Как генерировать WSO2 TEXT события, если значения пр запятая?

2. (если пункт 1 невозможен) В моем пользовательском адаптере MessageType, если я добавляю либо только ТЕКСТ, либо все 3 (TEXT, XML, JSON), он отлично работает. Но если я добавлю только JSON, я получаю ниже ошибки. Моя цель - добавить только JSON и преобразовать все CSV в JSON, чтобы избежать путаницы.

   [2016-09-19 15:38:02,406] ERROR {org.wso2.carbon.event.receiver.core.EventReceiverDeployer} - Error, Event Receiver not deployed and in inactive state, Text Mapping is not supported by event adapter type file

Answer 1

Я только что сделал это. Не изящный способ. Однако это сработало хорошо для меня.

Как я уже говорил, формат JSON является самым гибким для меня. Я читаю из файла и конвертирую каждую строку/событие в формат WSO2 JSON.

Проблема с этой опцией была, я хочу ограничить формат сообщения только JSON из консоли управления (меню «Формат сообщения» при создании нового ресивера). Если я добавлю только JSON [supportInputMessageTypes.add(MessageType.JSON)], он показывает ошибку, как я уже упоминал в вопросе № 2 выше.

Решение, вместо статической переменной из класса MessageType, непосредственно использует соответствующую строку. Итак, мой метод «getSupportedMessageFormats()» в EventAdapterFactory класса, как показано ниже:

@Override public List<String> getSupportedMessageFormats() { List<String> supportInputMessageTypes = new ArrayList<String>(); // just converting the type to string value // to avoid error "Text Mapping is not supported by event adapter type file" String jsonType = MessageType.JSON; supportInputMessageTypes.add(jsonType); //supportInputMessageTypes.add(MessageType.JSON); //supportInputMessageTypes.add(MessageType.XML); //supportInputMessageTypes.add(MessageType.TEXT); return supportInputMessageTypes; }

Моя просьба к команде WSO2, пожалуйста, позвольте тип файла адаптер событий в формате JSON.

Спасибо, Обэйд

Answer 2

Для чтения из CSV-файла и нажать события в поток, вы можете использовать адаптер файл хвост. См. Образец «Receiving Custom RegEx Text Events via File Tail». Этот образец содержит шаблоны регулярных выражений, которые вы можете использовать для сопоставления ввода CSV.

В дополнение к этому, как Charini в комментарии, вы также можете ознакомиться с event simulator. Однако симулятор событий не является приемником событий, то есть он не будет получать события в режиме реального времени, скорее он будет «играть» ранее определенный набор событий (в этом случае в файле CSV), чтобы имитировать поток событий. Он не будет постоянно контролировать файл для новых событий. Если вы хотите отслеживать файл для новых событий, подумайте об использовании адаптера файла-хвоста.