So erstellen Sie komplexe Typen mit Azure Stream Analytics-Abfragen

Question

Ich versuche, flache JSON-Daten von einem Event Hub in eine DocumentDB umzuwandeln. Die Zielstruktur soll wie folgt aussehen:

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

von der Quelle Erstellt:

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

Ich habe die Dokumentation von Azure-Stream Analytics, aber es IST keine klare Beschreibung, wie eine richtige Abfrage zu erstellen.

Wer kann mir helfen?

Answer 1

Sie können the new JavaScript UDF feature verwenden, um verschachtelte JSON-Objekte für die Ausgabe zu schreiben.

eine benutzerdefinierte Funktion Register "UDF.getDetails()" wie folgt:

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); 
} 

rufen Sie dann die UDF in der Abfrage eine Reihe von verschachtelten JSON-Objekt zu erhalten.

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