使用Azure功能作为Stream Analytics的输出：连接测试失败

Question

我有一个Azure流分析作业，它使用Azure功能作为输出。我通过CI / CD部署ASA作业以及功能。当我部署ASA作业时（假设存在AF），部署成功并且作业成功启动。此外，AF被成功触发（即输出起作用并且它不是例如与TSL设置有关的问题 - > Connection Test Failed when trying to add an Azure function as an output sink to Stream Analytics Job）。

但是，当我进行连接测试时，它会失败：

为什么连接测试失败？

Answer 1

在测试连接的运行状况时，空批处理从ASA发送到AF。问题是我正在处理空批处理，返回500响应，最终导致连接测试失败。

为了避免这个问题，有必要实现另一种处理空批处理的方法：

// Get and deserialize input content
string content = await req.Content.ReadAsStringAsync();
dynamic asaInput = JsonConvert.DeserializeObject(content);

// Handle empty input
if (asaInput is null || asaInput.Count == 0)
{
    log.Info("Received an empty request body...");
    return req.CreateResponse(HttpStatusCode.NoContent);
}