Azure Stream Analytics 쿼리로 복잡한 유형을 생성하는 방법

Question

이벤트 허브에서 편평한 JSON 데이터를 DocumentDB로 변환하려고합니다. 소스에서 생성

{ 
    "id" : 1 
    "field_1" : "value_1", 
    "details" : { 
     "detail_field_1":"abc", 
     "detail_field_2":"def" 
    } 
} 

: 대상 구조가 같아야합니다

{ 
    "id":1, 
    "field_1" : "value_1", 
    "detail_field_1":"abc", 
    "detail_field_2":"def" 
} 

나는 푸른 스트림 분석의 설명서를 확인하지만 적절한 쿼리를 만드는 방법에 대한 명확한 설명이 인도 표준시 없습니다.

누가 나를 도울 수 있습니까?

Answer 1

the new JavaScript UDF feature을 사용하면 중첩 된 JSON 객체를 출력하여 출력 할 수 있습니다.

사용자 정의 함수를 등록

"UDF.getDetails는()"아래 :

function main(obj) { 
    //get details object from input payload 
    var details_obj = {}; 

    details_obj.detail_field_1 = obj.detail_field_1; 
    details_obj.detail_field_2 = obj.detail_field_2; 

    return JSON.stringify(details_obj); 
} 

그런 다음 중첩 된 JSON 객체의 문자열을 얻을 수 있도록 쿼리에서 UDF를 호출합니다.

SELECT 
    id, 
    field_1, 
    UDF.getDetails(input) As details 
INTO output 
FROM input