azure - 使用 Azure Function 作为流分析的输出 : Connection Test Fails

Question

我有一个使用 Azure Function 作为输出的 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);
}