Azure流分析数据无法推送至Cosmos DB问题排查请求

• 查询逻辑错误：
  • 检查Stream Analytics的查询语句，确认是否用了SELECT *确保所有流入数据被输出，或者是否存在错误的WHERE条件过滤掉了全部数据。
  • 验证查询中的INTO子句是否指定了正确的Cosmos DB输出别名，拼写错误会导致数据无法路由到目标输出。
• Cosmos DB容器配置不匹配：
  • 核对Stream Analytics输出配置的分区键是否和Cosmos DB容器的分区键完全一致（区分大小写），不匹配会直接导致写入失败。
  • 检查容器的RU/s吞吐量是否足够，若吞吐量被耗尽，写入请求会被限流，数据无法落地到Cosmos DB。
• Stream Analytics输出配置细节遗漏：
  • 查看是否开启了批量写入，若批量阈值设置过高，数据可能还在缓存中未触发写入，可临时调低批量大小或等待一段时间观察。
  • 确认文档ID字段配置：如果指定了自定义ID，需确保数据流中存在该字段且值唯一，重复ID会导致覆盖或写入失败；若未指定，需确认自动生成ID的配置是否正常生效。
• 权限与网络限制：
  • 检查Stream Analytics的托管标识（系统或用户分配）是否拥有Cosmos DB的写入权限，比如Cosmos DB Contributor角色，或包含Microsoft.DocumentDB/databaseAccounts/sqlDatabases/containers/items/write权限的自定义角色。
  • 确认Cosmos DB的防火墙/虚拟网络设置是否允许Stream Analytics访问：如果设置了IP白名单，需添加Stream Analytics的出站IP；如果用了虚拟网络集成，需确保两者网络连通。
• 作业状态与监控排查：
  • 查看Stream Analytics作业的监控指标，比如Output Events是否有数据输出，Failed Output Events是否不为零。若有失败事件，可在作业的“日志”或“诊断设置”中查看具体错误信息，定位问题根源。
  • 确认作业处于运行状态，若近期有暂停或重启，可能需要等待一段时间恢复数据写入。
• 数据格式兼容性问题：
  • 检查IoT Hub流入的数据格式（如JSON）是否符合Cosmos DB要求，比如是否存在未转义的特殊字符导致解析失败。
  • 验证Stream Analytics输入配置的事件序列化格式是否与IoT Hub发送的数据格式匹配（如JSON、Avro），格式不匹配会导致数据无法被正确解析，进而无法输出到Cosmos DB。

内容的提问来源于stack exchange，提问作者nr.iras.sk