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

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

时间:2024-05-27 20:22:09浏览次数:15  
标签:Account Stream 错误 storage Azure Analystics data

问题描述

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]

标签:Account,Stream,错误,storage,Azure,Analystics,data
From: https://www.cnblogs.com/lulight/p/18216447

相关文章

  • 调用三方接口,outputStream.write传参数中参数怎么写,在转化成字节数组之前,是A=a&B=b的
    当您调用第三方接口并通过OutputStream.write()方法发送参数时,如果接口期望的是application/x-www-form-urlencoded类型的参数(常见于POST请求中提交表单数据),那么您确实需要将参数转换成A=a&B=b这样的格式,然后再将这个字符串转换成字节数组。以下是转换和发送这种类型参数的步骤:......
  • 调用三方接口,outputStream.write传参数中参数怎么写
    当您调用一个第三方接口并需要使用OutputStream.write()方法发送数据时,您通常需要将数据转换为字节格式,因为write()方法接受的是字节(byte)、字节数组(byte[])或字节数组的一个子序列作为参数。以下是几种常见的情况和相应的示例:发送字节数组:如果您已经有了一个字节数组,您可以直接......
  • Java 8 中Stream用法
    Stream是Java8新增的接口,Stream可以认为是一个高级版本的Iterator。废话不多说直接上代码 packagecom.example.demo;importorg.junit.jupiter.api.Test;importorg.springframework.boot.test.context.SpringBootTest;importjava.util.Arrays;importjava.util.L......
  • stream( ).collect ( Collectors.groupingBy ( ) ) 的用法
    文章目录第一种解释1、基本用法2、指定值收集器3、多级分组4、常见应用场景和用处第二种解释1、基本语法2、示例3、更复杂的用法第一种解释Collectors.groupingBy是Java8引入的StreamAPI中的一个收集器(Collector),它用于将流(Stream)中的元素根据某个分类函数......
  • Stream流的使用
    目录一,Stream流1.1概述1.2Stream代码示例二,Stream流的使用2.1数据准备2.2创建流对象2.3中间操作filtermapdistinctsortedlimitskipflatMap2.4终结操作foreachcountmax&mincollect2.5查找与匹配anyMatchallMatchnoneMatchfindAnyfindFirst2.6......
  • 使用benthos 实现stream load入库到doris
    下面给出yaml配置,只有input和output,中间可以自定义数据转换pipeline当前的数据从kafka中取出来就是json格式,所以不需要进行处理转换,输出段使用http_client组件,配置批处理提高吞吐量input:broker:copies:9inputs:-kafka:addresses:......
  • Qt - Qt6中QTextStream类的setCodec方法没有了,怎么解决写中文文本乱码
    简介场景:程序在linux下运行,将中英文写入文本,将文本在windows上打开时,中文出现乱码 原Qt5中:QFilefile;file.open(QIODevice::WriteOnly|QIODevice::Text);QTextStreamtextStream(&file);textStream.setCodec("GBK");使用 QTextStream类的 setCodec方法即可解决上......
  • Redis Stream消息队列
    工具类部分内容packagecom.hwd.campus.common.redis.utils;importcom.hwd.campus.common.redis.constant.RedisKeyPrefixConst;importcom.hwd.campus.common.redis.service.RedisListSelect;importcom.hwd.campus.common.redis.service.RedisSelect;importlombok.AllA......
  • 在 Azure AI Studio 中创建项目并使用聊天演练场
    在AzureAIStudio中创建项目并使用聊天演练场See:CreateaprojectandusethechatplaygroundinAzureAIStudio-AzureAIStudio|MicrosoftLearn在本动手实验中,你将创建项目,部署聊天模型,然后在AzureAIStudio中的演练场中使用它。本动手实验包括:在AzureA......
  • stream流
    Stream流作用:结合lamada表达式,简化集合、数组的操作操作步骤1、获取Stream流单列集合⭐️Collection中的默认方法双列集合⭐️无法直接使用,需要配合keyset、entryset数组Arrays.stream(arr)零散数据需要同种数据类型Stream.of()2、中间方法filter......