Ошибка последовательности EI WSO2 при вызове службы данных - PullRequest
Новая
       122

Ошибка последовательности EI WSO2 при вызове службы данных

0 голосов
/ 05 декабря 2018

Запуск WSO2 EI 6.2.0

Моя последовательность очень проста:

  1. Получить 1 параметр (mac) из первоначального запроса
  2. Вызвать DS для извлечениявторой параметр (time_hour)
  3. Вызов DS с обоими параметрами (mac) и (time_hour)

При вызове обоих DS вручную, он отлично работает.

При вызове второго DS через ESB я получаю странную ошибку.

Последовательность: 

<?xml version="1.0" encoding="UTF-8"?>
<sequence name="udp_nxt_gethfcprofilecapacity" trace="enable" xmlns="http://ws.apache.org/ns/synapse">
    <property expression="$url:mac" name="uri.var.mac" scope="default"
        type="STRING" xmlns:ns="http://org.apache.synapse/xsd"/>
    <property name="mac" scope="default" type="STRING" value="get-property('uri.var.mac')"/>
    <call>
        <endpoint>
            <http method="GET" uri-template="http://rhtdflow001.corporativo.pt:8290/services/udp_nxt/gethfcprofilecapacity_hour?mac={uri.var.mac}"/>
        </endpoint>
    </call>
    <enrich>
        <source clone="true" type="body"/>
        <target action="replace" property="payload" type="property"/>
    </enrich>
    <log level="custom">
        <property expression="get-property('payload')" name="bbb" xmlns:ns="http://org.apache.synapse/xsd"/>
    </log>
    <property expression="$ctx:payload//ns2:hour" name="time_hour"
        scope="default" type="STRING"
        xmlns:ns="http://org.apache.synapse/xsd" xmlns:ns2="http://ws.wso2.org/dataservice"/>
    <header action="remove" name="Content-Type" scope="transport"/>
    <log level="custom">
        <property expression="get-property('uri.var.mac')" name="mac" xmlns:ns="http://org.apache.synapse/xsd"/>
    </log>
    <log level="custom">
        <property expression="get-property('time_hour')"
            name="time_hour" xmlns:ns="http://org.apache.synapse/xsd"/>
    </log>
    <call>
        <endpoint>
            <http method="GET" uri-template="http://rhtdflow001.corporativo.pt:8290/services/udp_nxt/gethfcprofilecapacity?mac={uri.var.mac}&amp;hour={time_hour}"/>
        </endpoint>
    </call>
    <log level="custom">
        <property name="xxx" value="FIM"/>
    </log>
    <respond/>
</sequence>

Я пытаюсь записать параметры перед вызовом DS, и они правильно напечатаны, но когда яиспользуйте его в DS Call, параметр hour={time_hour} пуст.

Вывод и ошибка: 

(...)
TID: [-1234] [] [2018-12-05 12:24:02,562]  INFO {org.apache.synapse.mediators.builtin.LogMediator} -  mac = 0003081B9E70 {org.apache.synapse.mediators.builtin.LogMediator}
TID: [-1234] [] [2018-12-05 12:24:02,562]  INFO {org.apache.synapse.mediators.builtin.LogMediator} -  time_hour = 2018-12-03T11:00:00.000+00:00 {org.apache.synapse.mediators.builtin.LogMediator}
TID: [-1234] [] [2018-12-05 12:24:02,569] ERROR {org.wso2.carbon.dataservices.core.DBInOutMessageReceiver} -  Error in in-out message receiver {org.wso2.carbon.dataservices.core.DBInOutMessageReceiver}
DS Code: DATABASE_ERROR
Nested Exception:-
javax.xml.stream.XMLStreamException: DS Fault Message: Error in 'SQLQuery.processPreNormalQuery': DS Fault Message: Error processing parameter - hour, Error - DS Fault Message: Empty string or null value was found as timeStamp.
DS Code: UNKNOWN_ERROR

DS Code: UNKNOWN_ERROR
Nested Exception:-
DS Fault Message: Empty string or null value was found as timeStamp.
DS Code: UNKNOWN_ERROR


DS Code: DATABASE_ERROR
Source Data Service:-
Name: udp_nxt
Location: /udp_nxt.dbs
Description: UDP Call to NXT
Default Namespace: http://ws.wso2.org/dataservice
Current Request Name: _getgethfcprofilecapacity
Current Params: {hour=, mac=0003081B9E70}
Nested Exception:-
DS Fault Message: Error processing parameter - hour, Error - DS Fault Message: Empty string or null value was found as timeStamp.
DS Code: UNKNOWN_ERROR
(...)

Любой знает, как правильно связать параметр time_hour со службами данных вESB Sequence?

Объяснение того, почему переменная time_hour не оценивалась

Из WSO2 Документация :

Шаблоны URI позволяют RESTful URI содержать переменные, которые могут быть заполненыСреда выполнения вызова с использованием значений свойств, имена которых имеют префикс "uri.var" .

Финальная последовательность, которая работает на основе ответа Яна: 

<?xml version="1.0" encoding="UTF-8"?>
<sequence name="udp_nxt_gethfcprofilecapacity" trace="enable" xmlns="http://ws.apache.org/ns/synapse">
    <property expression="$url:mac" name="uri.var.mac" scope="default"
        type="STRING" xmlns:ns="http://org.apache.synapse/xsd"/>
    <call>
        <endpoint>
            <http method="GET" uri-template="http://rhtdflow001.corporativo.pt:8290/services/udp_nxt/gethfcprofilecapacity_hour?mac={uri.var.mac}"/>
        </endpoint>
    </call>
    <enrich>
        <source clone="true" type="body"/>
        <target action="replace" property="payload" type="property"/>
    </enrich>
    <property expression="$ctx:payload//ns2:hour"
        name="uri.var.time_hour" scope="default" type="STRING"
        xmlns:ns="http://org.apache.synapse/xsd" xmlns:ns2="http://ws.wso2.org/dataservice"/>
    <header action="remove" name="Content-Type" scope="transport"/>
    <call>
        <endpoint>
            <http method="GET" uri-template="http://rhtdflow001.corporativo.pt:8290/services/udp_nxt/gethfcprofilecapacity?mac={uri.var.mac}&amp;hour={uri.var.time_hour}"/>
            <property name="time_h" value="{time_hour}"/>
        </endpoint>
    </call>
    <respond/>
</sequence>

1 Ответ

0 голосов
/ 05 декабря 2018

Для использования в качестве переменной uri-template требуется 'uri.var' в качестве имени переменной.

Поэтому создайте свойство с текущим временем.(Я удивлен, кстати, что 'time_hour' работает для вас, в моем случае я использовал SYSTEM_DATE, time_hour возвращается к 'null') 

<property expression="get-property('SYSTEM_DATE')" name="uri.var.time_hour"/>

и использую это в вашей конечной точке.

...