【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月前
|
存储
【Azure 事件中心】Event Hubs中存在非常多的错误数据,是否能提前删除这些数据呢?
【Azure 事件中心】Event Hubs中存在非常多的错误数据,是否能提前删除这些数据呢?
|
3月前
|
算法 数据处理 流计算
流计算引擎数据问题之传播模块工作如何解决
流计算引擎数据问题之传播模块工作如何解决
39 1
|
3月前
|
消息中间件 安全 机器人
【Azure 事件中心】Kafka 生产者发送消息失败,根据失败消息询问机器人得到的分析步骤
【Azure 事件中心】Kafka 生产者发送消息失败,根据失败消息询问机器人得到的分析步骤
|
5月前
|
消息中间件 存储 Serverless
函数计算产品使用问题之想要请求持久化该怎么操作
函数计算产品作为一种事件驱动的全托管计算服务,让用户能够专注于业务逻辑的编写,而无需关心底层服务器的管理与运维。你可以有效地利用函数计算产品来支撑各类应用场景,从简单的数据处理到复杂的业务逻辑,实现快速、高效、低成本的云上部署与运维。以下是一些关于使用函数计算产品的合集和要点,帮助你更好地理解和应用这一服务。
|
4月前
|
Oracle 数据库 流计算
实时计算 Flink版产品使用问题之通过打印sourceRecord发现没有收到丢失的数据,是什么导致的
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
6月前
|
SQL 关系型数据库 Java
实时计算 Flink版操作报错之读取业务库数据,提示类型转换错误,该怎么处理
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
6月前
|
JavaScript 前端开发 Java
流的概念,怎么处理
流的概念,怎么处理
|
6月前
|
NoSQL Java 数据处理
实时计算 Flink版产品使用合集之处理数据同步时出现异常,想要在遇到异常时发送邮件通知,如何捕获并处理这些异常
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
Java 程序员
Stream流操作-结果收集终止方法-最终篇
Stream流操作-结果收集终止方法-最终篇
106 0