azure - 将分析出站流式传输到 Azure Functions

Question

几天前，微软宣布支持将数据从 Azure Stream Analytics 发送到 Azure Functions:

https://azure.microsoft.com/en-us/blog/new-in-stream-analytics-output-to-azure-functions-built-in-anomaly-detection-etc/

我尝试了此操作，但无法将数据发送到 Azure Functions。是否有任何指南如何从 IoT-hub -> Azure Stream Analytics -> Azure Functions 发送数据包？

输出对于其他来源来说很好。这是我的查询:

WITH rpidata AS
(
SELECT 
*, 
DATEADD(Hour, 3, timecreated) AS FITimezone
FROM [rpi]
)
SELECT *
INTO [PowerBI]
FROM rpidata
SELECT *
INTO [storageout]
FROM rpidata
SELECT *
INTO [fnout]
FROM rpidata

我收到的错误消息是:

Could not successfully send an empty batch to the Azure Function. Please make sure your function app name, function name, and API key are correct and that your Azure Function compiles. If all of those parameters are correct, Azure Function may be temporarily available at this time. Please try again later. Azure function returned with response code of 500: InternalServerError. It should respond with a 200, 202, or 204.

但是，该函数存在，正在运行，并且当我尝试创建连接时会自动找到该函数。

我应该使用什么样的函数输入来接收数据？在示例中，我链接的函数名称是 httptriggercsharp...streamjob 是否以 json 形式发送数据？

Answer 1

不确定您是否仍然需要此功能，但供将来引用:ASA 作业会将 JSON 数组中的数据输出到您的 Azure 函数。像这样的 ASA 查询示例

SELECT
   w.col1 as key1,
   w.col2 as key2,
   System.Timestamp as time
INTO
   azfunction
FROM
   [input] w;

将像这样到达你的函数

[
         {
             "key1":"value1",
             "key2":"value2",
             "time":"2017-09-04T17:51:02.7986986Z"
         },
         {
             "key1":"value3",
             "key2":"value4",
             "time":"2017-09-04T17:51:02.7986986Z"
         }
]

JSON 数组将包含多少元素，取决于您在 ASA 中设置 Az 函数输出的方式以及事件到达 ASA 的速度。该数组可能只有 1 个元素或 100 个元素，具体取决于您的场景。