【Azure Stream Analystics】流分析服务执行遇见警告错误消息,导致上游数据堆积,下游无任何输出

简介: 【Azure Stream Analystics】流分析服务执行遇见警告错误消息,导致上游数据堆积,下游无任何输出

问题描述

Azure Stream Analystics服务运行状态正常,测试输出也正常。但是下游没有任何数据产生。

只是在概述页面中提示:

Message:Encountered error trying to discover new reference data snapshot.

Error: The job hasencountered error from Reference Data storage. Error encountered while storingreference data snapshot into the storage account.

 

问题解答

根据错误信息,找到是SQL输入源中有错误消息。但是测试数据库连接的时候,连接时成功的。

认真分析错误消息:

尝试发现新的引用数据快照时遇到了错误。错误: The job has encountered error from Reference Data storage. Error encountered while storing reference data snapshot into the storage account.

通常,访问Storage Account 出错是因为防火墙。在检查Storage  Account网络设置后,果然,它只允许特定的网络访问,在为 Stream Analystics 服务启用了 Resource Instances后,发现问题依旧。只有当配置为全部网络都可以访问Storage Account后,问题才消失。

不得其解啊!明明指定了Microsoft.StreamAnalystics/streamingjobs, 那为什么不行呢? 最后,找到流分析(Stream Analystics)配置SQL输入源的文档:https://docs.azure.cn/zh-cn/stream-analytics/sql-database-output-managed-identity?tabs=azure-sql#additional-steps-for-sql-reference-data,  特别强调:若要使用连接字符串进行身份验证,必须禁用存储帐户防火墙设置。如此看来,这就是一个产品的设定,没有道理可讲!

 

 

 

[END]

相关文章
|
2月前
|
Python
8. 如何解决 Tornado 检测到了有事件(events)被发送到一个已经关闭的流(stream)。在 Tornado 中,一个流代表一个请求或响应的数据流。这个警告可能意味着在请求处理的过程中,
8. 如何解决 Tornado 检测到了有事件(events)被发送到一个已经关闭的流(stream)。在 Tornado 中,一个流代表一个请求或响应的数据流。这个警告可能意味着在请求处理的过程中,
|
3月前
|
存储 开发工具 C#
【Azure 事件中心】从Azure Event Hub中消费数据,如何查看当前消费客户端消费数据的Offset和SequenceNumber呢(消息偏移量和序列号)?
【Azure 事件中心】从Azure Event Hub中消费数据,如何查看当前消费客户端消费数据的Offset和SequenceNumber呢(消息偏移量和序列号)?
|
3月前
|
算法 数据处理 流计算
流计算引擎数据问题之传播模块工作如何解决
流计算引擎数据问题之传播模块工作如何解决
39 1
|
3月前
|
消息中间件 安全 机器人
【Azure 事件中心】Kafka 生产者发送消息失败,根据失败消息询问机器人得到的分析步骤
【Azure 事件中心】Kafka 生产者发送消息失败,根据失败消息询问机器人得到的分析步骤
|
4月前
|
缓存 流计算
explorer链接失败报错和延迟问题之Blink参数优化来限制读取日志流的TPS的问题如何解决
explorer链接失败报错和延迟问题之Blink参数优化来限制读取日志流的TPS的问题如何解决
|
6月前
基于若依的ruoyi-nbcio流程管理系统支持支持定时边界事件和定时捕获事件
基于若依的ruoyi-nbcio流程管理系统支持支持定时边界事件和定时捕获事件
80 2
|
6月前
|
JavaScript 前端开发 Java
流的概念,怎么处理
流的概念,怎么处理
|
Java 程序员
Stream流操作-结果收集终止方法-最终篇
Stream流操作-结果收集终止方法-最终篇
106 0
|
消息中间件 存储 网络协议
大厂都是如何处理重复消息的?
消息消费失败,很多框架会自动执行重试,而重试就产生了重复消息。 MQTT协议给出三种传递消息时能够提供的
275 0
|
消息中间件 RocketMQ
一个应用尽可能用一个Topic是最佳实践吗?没理解就用保证出错
RocketMQ 官方提供的基本最佳实践第一条,分享自己的一点心得,有问题欢迎大家指出~ > 一个应用尽可能用一个Topic,而消息子类型则可以用tags来标识。tags可以由应用自由设置,只有生产者在发送消息设置了tags,消费方在订阅消息时才可以利用tags通过broker做消息过滤:message.setTags("TagA")。
一个应用尽可能用一个Topic是最佳实践吗?没理解就用保证出错