Блог

Мы настроили платформу Confluent с помощью docker на машине с 4 микроконтроллерами. Мы пытаемся использовать KSQL для выполнения преобразования входящих сообщений перед отправкой их в Salesforce.

 ksqlgt; describe serviceorder; Name : SERVICEORDER Field | Type -------------------------------------------------------------------------------------------------------------------------------------- SCHEMALOCATION | VARCHAR(STRING)   EVENTID | VARCHAR(STRING)   EVENTTIME | VARCHAR(STRING)   EVENTTYPE | VARCHAR(STRING)   CORRELATIONID | VARCHAR(STRING)   DOMAIN | VARCHAR(STRING)   TITLE | VARCHAR(STRING)   DESCRIPTION | VARCHAR(STRING)   PRIORITY | VARCHAR(STRING)   EVENT | STRUCTlt;SERVICEORDER STRUCTlt;ID VARCHAR(STRING), STATE VARCHAR(STRING), ORDERDATE VARCHAR(STRING), STARTDATE VARCHAR(STRING), COMPLETIONDATE VARCHAR(STRING), CATEGORY VARCHAR(STRING), DESCRIPTION VARCHAR(STRING), EXTERNALID VARCHAR(STRING), PRIORITY VARCHAR(STRING), REQUESTEDCOMPLETIONDATE VARCHAR(STRING), REQUESTEDSTARTDATE VARCHAR(STRING), REPLYTOADDRESS VARCHAR(STRING), RELATEDPARTY ARRAYlt;STRUCTlt;ROLE VARCHAR(STRING), ID VARCHAR(STRING), NAME VARCHAR(STRING)gt;gt;, TYPE VARCHAR(STRING), ERRORMESSAGE ARRAYlt;STRUCTlt;CODE VARCHAR(STRING), MESSAGE VARCHAR(STRING), REASON VARCHAR(STRING), STATUS VARCHAR(STRING), TIMESTAMP VARCHAR(STRING)gt;gt;, SERVICEORDERITEM ARRAYlt;STRUCTlt;ID VARCHAR(STRING), ACTION VARCHAR(STRING), SERVICE STRUCTlt;ID VARCHAR(STRING), NAME VARCHAR(STRING), STATE VARCHAR(STRING), SERVICETYPE VARCHAR(STRING), SERVICESPECIFICATION STRUCTlt;NAME VARCHAR(STRING)gt;, SERVICECHARACTERISTIC ARRAYlt;STRUCTlt;NAME VARCHAR(STRING), VALUE VARCHAR(STRING)gt;gt;, SERVICERELATIONSHIP ARRAYlt;STRUCTlt;ID VARCHAR(STRING), RELATIONSHIPTYPE VARCHAR(STRING), SERVICE VARCHAR(STRING)gt;gt;, PLACE ARRAYlt;STRUCTlt;ID VARCHAR(STRING), NAME VARCHAR(STRING), ROLE VARCHAR(STRING)gt;gt;, RELATEDENTITY ARRAYlt;STRUCTlt;ID VARCHAR(STRING), NAME VARCHAR(STRING), ROLE VARCHAR(STRING), STATE VARCHAR(STRING)gt;gt;, RELATEDPARTY ARRAYlt;STRUCTlt;ID VARCHAR(STRING), NAME VARCHAR(STRING), ROLE VARCHAR(STRING)gt;gt;, NOTE ARRAYlt;STRUCTlt;ID VARCHAR(STRING), AUTHOR VARCHAR(STRING), DATE VARCHAR(STRING), TEXT ARRAYlt;VARCHAR(STRING)gt;gt;gt;, SERVICEORDERITEMRELATIONSHIP ARRAYlt;STRUCTlt;RELATIONSHIPTYPE VARCHAR(STRING), ORDERITEM STRUCTlt;ITEMID VARCHAR(STRING)gt;gt;gt;gt;gt;gt;gt;gt;  --------------------------------------------------------------------------------------------------------------------------------------  For runtime statistics and query details run: DESCRIBE lt;Stream,Tablegt; EXTENDED;  

Всякий раз, когда мы выполняем запрос по полям структуры или массива, интерфейс командной строки KSQL зависает и выходит из памяти. Есть идеи?

пример запроса

 select EVENT-gt;SERVICEORDER-gt;SERVICEORDERITEM[1]-gt;ID as ID from serviceorder emit changes limit 1;