Azure Stream Analytics konnte die Azure-Funktion nicht auslösen

Question

Ich habe eine Azure-Funktion erstellt, um das Ergebnis an das Gerät zurückzugeben, wenn das Gerät Daten an den Azure IoT-Hub sendet. Ich folge dem tutorial, um die Ausgabe an SQL- und Azure-Funktion zu senden. Hier ist meine ASA-Abfrage.

WITH subquery as (
    SELECT 
    messageId, 
    deviceId, 
    temperature, 
    humidity, 
    EventProcessedUtcTime, 
    DemoML(temperature, humidity) as result1 
    from DemoInput 
    ) 

SELECT 
    messageId as messageId, 
    deviceId as deviceId, 
    temperature as temperature, 
    humidity as humidity, 
    EventProcessedUtcTime as EventProcessedUtcTime, 
    result1.[Scored Labels] as result, 
    result1.[Scored Probabilities] as resultProbability 
INTO 
    [DemoOutput] 
FROM 
    [subquery] 


SELECT 
    * 
INTO 
    [c2d] 
FROM 
    [subquery] 

Ich weiß nicht, warum es die Azure-Funktion nicht auslösen würde. Aber wenn ich die letzte Zeile von [Unterabfrage] zu [DemoInput] ändere, wird es funktionieren. Warum ist das passiert?

Answer 1

Versuchen Sie die folgende Abfrage nur zu Testzwecken. Beachten Sie, dass ich Ihre DemoML-Funktion herausgenommen habe und die Ausgabe für Blob-Speicher ist. Sie sollten die Ausgänge im AF- und Blob-Speicher sehen:

WITH subquery as (
    SELECT 
     System.Timestamp as time, 
     temperature, 
     humidity, 
     EventProcessedUtcTime, 
     IoTHub.ConnectionDeviceId as deviceId, 
     IoTHub.MessageId as messageId 
    FROM 
     DemoInput Timestamp by time 
    ) 

SELECT 
    messageId as messageId, 
    deviceId as deviceId, 
    temperature as temperature, 
    humidity as humidity, 
    EventProcessedUtcTime as EventProcessedUtcTime 
INTO 
    DemoOutputBlob 
FROM 
    subquery 


SELECT 
    * 
INTO 
    c2d 
FROM 
    subquery