Не удалось выполнить пример ответа на синхронный запрос в Siddhi
Я пытаюсь запустить пример кода дано в документации WSO2 Siddhi.
Я воспроизвел то, что там было дано.
@App:name("Http_Request_Response_Tutorial")
@App:description("This app demonstrate the usage of http request sink and http response source")
@source(type='http-response' ,sink.id='cardTypeSink',
@map(type='xml', namespaces = "xmlns=http://localhost/SmartPayments/",
@attributes(creditCardNo = 'trp:creditCardNo',creditCardType = ".")))
@sink(type='log')
define stream EnrichedCreditCardStream (creditCardNo string,creditCardType string);
@sink(type='http-request',publisher.url='https://secure.ftipgw.com/ArgoFire/validate.asmx/GetCardType',method='POST', headers="'Content-Type:application/x-www-form-urlencoded'",
sink.id="cardTypeSink",
@map(type='keyvalue', @payload(CardNumber='{{creditCardNo}}')))
define stream CreditCardStream (creditCardNo string);
На вкладке «Имитатор событий» я передал значения, указанные в примере, а именно: 154467847759 в поле метки времени и 5555555555554444 в номер кредитной карты (STRING).
Это ошибка, которая приходит.
[2019-05-22_14-59-14_632] ERROR {org.wso2.extension.siddhi.io.http.source.HttpResponseMessageListener} - No source of type 'http-response' for status code '500' has been defined. Hence dropping the response message. (Encoded)
3 метода стилизации элементов HTML
Когда дело доходит до применения какого-либо стиля к нашему HTML, существует три подхода: встроенный, внутренний и внешний. Предпочтительным обычно...
Формы c голосовым вводом в React с помощью Speechly
Пытались ли вы когда-нибудь заполнить веб-форму в области электронной коммерции, которая требует много кликов и выбора? Вас попросят заполнить дату,...
Стилизация и валидация html-формы без использования JavaScript (только HTML/CSS)
Будучи разработчиком веб-приложений, легко впасть в заблуждение, считая, что приложение без JavaScript не имеет права на жизнь. Нам становится удобно...
Flatpickr: простой модуль календаря для вашего приложения на React
Если вы ищете пакет для быстрой интеграции календаря с выбором даты в ваше приложения, то библиотека Flatpickr отлично справится с этой задачей....
В чем разница между Promise и Observable?
Разберитесь в этом вопросе, и вы значительно повысите уровень своей компетенции.
Что такое cURL в PHP? Встроенные функции и пример GET запроса
Клиент для URL-адресов, cURL, позволяет взаимодействовать с множеством различных серверов по множеству различных протоколов с синтаксисом URL.
0
0
300
2
Перейти к ответу
Данный вопрос помечен как решенный
Ответы 2
Согласно ошибке, я думаю, что вы не подключены к publisher.url в определении потока CreditCardStream.
Перед моделированием событий убедитесь, что CreditCardStream подключен к https://secure.ftipgw.com/ArgoFire/validate.asmx/GetCardType.
Если он успешно подключен, вы получите журналы, подобные следующим.
[2019-05-23 12:19:36,713] INFO {org.wso2.extension.siddhi.io.http.sink.HttpSink} - Http_Request_Response_Tutorial:@sink( type = "http-request", publisher.url = "https://secure.ftipgw.com/ArgoFire/validate.asmx/GetCardType", method = "POST", headers = "'Content-Type:application/x-www-form-urlencoded'", sink.id = "cardTypeSink", @map( type = "keyvalue", @payload( CardNumber = "{{creditCardNo}}")))define stream CreditCardStream (creditCardNo string) has successfully connected to https://secure.ftipgw.com/ArgoFire/validate.asmx/GetCardType
[2019-05-23 12:19:55,597] INFO {org.wso2.siddhi.core.stream.output.sink.LogSink} - Http_Request_Response_Tutorial : EnrichedCreditCardStream : [Event{timestamp=1558594195597, data=[5555555544444, ], isExpired=false}]
Я все еще получаю эту ошибку. Приведенное выше сообщение журнала появляется, когда я запускаю приложение siddhi.
—
23.05.2019 13:56
Ответ принят как подходящий
Согласно напечатанной ошибке, запрос, отправленный на https://secure.ftipgw.com/ArgoFire/validate.asmx/GetCardType, возвращает ответ 500. Поскольку у вас нет источника http-ответ для приема 500 ответов, полезная нагрузка ответа будет удалена.
Поведение, которое вы наблюдаете, не может быть воспроизведено с нашей стороны. Учебник работает правильно, как показано.
Ниже приведена измененная версия учебного примера с фиктивной конечной точкой. Можешь попробовать.
@App:name("Http_Request_Response_Tutorial")
@App:description("This app demonstrate the usage of http request sink and http response source")
@source(type='http-response' ,sink.id='cardTypeSink',
@map(type='xml', namespaces = "xmlns=http://localhost/SmartPayments/",
@attributes(creditCardNo = 'trp:creditCardNo',creditCardType = ".")))
@sink(type='log')
define stream EnrichedCreditCardStream (creditCardNo string,creditCardType string);
@sink(type='http-request',publisher.url='http://www.mocky.io/v2/5cee2fa1300000013a6e9961',method='POST', headers="'Content-Type:application/x-www-form-urlencoded'",
sink.id="cardTypeSink",
@map(type='keyvalue', @payload(CardNumber='{{creditCardNo}}')))
define stream CreditCardStream (creditCardNo string);
Другие вопросы по теме
Получайте события через HTTP-транспорт и просматривайте выходные данные на консоли с входными данными JSON.
Попытка сделать асинхронный запрос Api сохранить данные ответа как часть объекта
Множественные асинхронные HTTP-подключения к серверу Tornado
Как регулировать Grequests при выполнении асинхронных вызовов API?
Как управлять ограничением времени ожидания ответа 5 секунд в Dialogflow / Api.ai?
Как выбрать последний вызов api, когда было выполнено несколько вызовов api
Как сделать несколько вызовов API с запросами Python
Синтаксическая ошибка в SiddhiQL, нет жизнеспособной альтернативы при вводе '@sink'
Похожие вопросы
Как передать параметры функции прогнозирования тензорного потока в сиддхи?
В потоковом процессоре WSO2 учебник по обнаружению аномалий вызывает исключение
Siddhi - Business Rule Manager терпит неудачу при попытке развернуть
Как я могу запустить приложение siddhi из командной строки?
Как вставить исходное имя файла (входной файл) в определенный поток при использовании расширения siddhi-io-csv в siddhi при использовании WSO2SP
Как обработать входящее событие и на основе поля в событии записать в разные потоки с помощью wso2?
Требуемые заголовки манифеста пакета не существуют wso2
Агрегация данных siddhi по времени
Потоковый процессор WSO2 при подключении к Cassandra дает ошибку
В логах написано, что подключение успешное - INFO {org.wso2.extension.siddhi.io.http.sink.HttpSink} - Http_Request_Response_Tutorial:@sink( type = "http-request", publisher.url = "secure.ftipgw.com/ArgoFire/validate.asmx/GetCardType", method = "POST", headers = "'Content-Type:application/x-www-form-urlencoded'", sin.id = "cardTypeSink", @map( type = "keyvalue", @payload( CardNumber = "{{ CreditCardNo}}"))) определить поток CreditCardStream (строка CreditCardNo) успешно подключился к secure.ftipgw.com/ArgoFire/validate.asmx/GetCardType (закодировано)