-
0 votesanswersviews
将Azure流分析的输出设置为Event Hub
我正在尝试使用事件中心作为Azure流分析的输出接收器,并且下面显示了执行此操作的代码 . OutputCreateOrUpdateParameters jobOutputCreateParameters = new OutputCreateOrUpdateParameters() { Output = new Output() { ... -
0 votesanswersviews
Azure事件中心:它可以提取哪种类型的数据
Azure Stream Analytics是否只接受JSON文件? 您是否可以将事件管道分隔或其他文件格式提取/发送到Event Hub并从Stream Analytics中使用它们? -
2 votesanswersviews
如何使用UWP App实现将事件中心的值(通过流分析作业过滤后的值)发送到IoT Hub的逻辑?
我目前正致力于物联网,在我目前的项目中,我实施了向IoT Hub发送温度值的逻辑(使用Raspberry PI2和BMP280传感器),在天蓝色部分,我创建了流分析工作,用于接收来自物联网的消息根据我的查询集中并过滤这些值,如果温度值超过30度并将这些过滤后的值发布到事件中心是流分析作业的输出之一 . 我在流分析工作中写的查询 . SELECT System.timestamp AS Time... -
0 votesanswersviews
Blob存储输入在流分析作业输出查询中返回null
我'm beginner in Azure, I have created a Stream Analytics Job in Windows Azure. Here I' m在作业中使用两个输入,一个是 Event Hub 的类型,另一个是 Blob Storage 的类型 . 下面是ASA作业的SQL查询(在SQL数据库中存储输出): SELECT IP.DeviceId , ... -
0 votesanswersviews
Azure Streaming Analytics未找到任何活动
我们使用提供的JAVA SDK将示例json事件推送到azure事件中心 . 然后我们创建了流分析工作,它从事件中心获取输入并将数据推送到blob存储 . 但我们已经观察到(从监控)事件被推送到事件中心,但我的流分析工作既没有接收事件也没有抛出任何异常(查看活动日志) . 我尝试了互联网上提供的所有故障排除解决方案,但仍无法正常工作 . 概览页面上的图表中未显示任何输入事件 注意:我使用azure... -
0 votesanswersviews
Azure Stream Analytics事件中心输出 - 收到无效对象
使用ASA作业将输入作为IoT Hub和Event Hub作为输出,使用一个流式传输单元和每秒36条消息 . ASA将多个对象作为单个字符串发送到事件中心 . 例如 . - 当我通过上传示例IoT Hub输入json文件来测试ASA作业时,获取单行中的跟随对象(输出中每行一个对象),这是预期的 - “{”assetbarcode“:”MobileGW153353803144884Asset“,”... -
1 votesanswersviews
从Azure功能向Azure Event Hub发布事件:无法为当前会话或连接分配更多句柄
我们有一个Azure功能,它通过内置的事件中心集成绑定将消息发布到Azure事件中心,然后用于提供流分析作业 . 这一切都运行良好然后突然昨晚我们开始在写入事件中心的Azure功能中收到以下错误: Exception while executing function: Functions.LocationEventPublish. Microsoft.Azure.WebJobs.Script: O... -
0 votesanswersviews
指定监视器诊断设置'send interval'
我想知道如何增加azure监视器向eventhub发送诊断设置的频率 . 我正在使用Redis资源中的诊断设置将指标转发到eventhub . 从那里他们被自定义监控 stack 摄取 . 诊断通过以下方式设置: az monitor diagnostic-settings create -n eh-meh \ --resource $REDIS_ID --event-hub redis-metr... -
0 votesanswersviews
Azure EventHub上的Qpid接收器
我已经基于Azure EventHub工作了应用程序 . 现在我需要编写连接到现有基础架构的java接收器 . 现有配置: 事件中心> SomeName>使用者组> SomeGroupName 在管理控制台中,我看不到任何QUEUE或TOPIC定义 . 分析工作的c#代码我可以看到hub-name group-name足以连接 . 我重建了url,允许我通过java连接(到目前为... -
0 votesanswersviews
使用QPid和golang包装器Electron连接到AMQP 1.0 Azure EventHub
我想使用Electron golang包装器为Qpid proton-c库连接到Azure EventHub . 我将以下SASL详细信息组合到构建连接字符串所需的host / port / namespace / path但由于某种原因我不断收到错误消息: connection reset by peer . package main import ( "fmt"... -
1 votesanswersviews
GPRS 设备和 Azure IOT Hub 问题
我们正在开发一个系统,其中配备有 Simcom SIM800 GPRS 模块的多个设备需要使用 AT 命令将遥测数据发送到端口 443 处的 IoT 中心,以获取到 Azure REST API 端点的 GET 和 POST 数据。 https:// {。 1} .azure-devices.net/devices/ {。 2} /messages/events?api-version = {。... -
0 votesanswersviews
无法通过Event Hub收到有关Azure Stream Analytics的输入
我尝试使用Event Hub将消息发送到Azure Stream Analytics . 在Azure上,我清楚地看到监视器上的事件活动,但在Stream Analytics Job上,我只是无法测试输入数据 . 我试图只测试一个文件,它的工作原理我的json文件没问题 . 在我用来发送消息的C#代码下面: using System; using System.Collections.Generi... -
0 votesanswersviews
从spark DStream中获取的RDD不会在分区之间分配
我有五个执行程序为这个spark作业运行,但来自dstream的RDD只分配在两个分区之间 . 如果我做 repartion(5) 然后它仍然分布在2个分区中,但是当我通过执行 val newrdd= sparkcontext.parallelize(rdd.take(rdd.count())) 创建一个新的RDD时,它会正确地分布在5个分区中 . 但是在并行化现有RDD之后创建一个新的RDD并不... -
8 votesanswersviews
Azure DocumentDB读取文档资源未找到
我正在构建一个.Net控制台应用程序来读取DocumentDB中的信息 . 控制台应用程序具有来自EventHub的数据,并在进入 Cloud 时插入/更新最新数据 . 我正在尝试从DocumentDB读取单个文档,我可以在请求文档之前确认文档存在 . if (DocumentDBRepository<DocumentDBItem>.DoesItemExist(name)) { ... -
4 votesanswersviews
EventHub异常:无法为当前会话或连接分配更多句柄
我有C#控制台应用程序,通过它我经常将数据发送到事件中心 . 这个控制台应用程序基本上从SQL存储读取一些数据并开始将数据推送到事件中心 . 整个程序以无限循环/方式运行,就像在控制中一样,只要它在SQL中接收任何数据,它就从那里提取数据并开始发送到事件中心 . 但是有一刻我得到了这个错误 . “无法为当前会话或连接分配更多句柄 . 允许的最大句柄数为4999.请释放资源再试一次 . 在Micro... -
4 votesanswersviews
Azure流分析太慢 - 时间值也是无关紧要的
我们希望将我们的专用服务器迁移到Azure平台,以便轻松扩展,并根据我们的需求调查了大量Azure服务 . 因此,我们要使用的Azure服务之一是Azure流分析(ASA) . 我们根据我们执行某些测试的需要添加了一些Azure平台(目前它们的用途并不重要) . 这是结构: SimpleApp (Sending Request, Not In Azure) -> Event Hub 1 (E... -
1 votesanswersviews
Azure EventHubTrigger功能应用程序中的偏移量
Expectation: 使用带有EventHubTrigger-CSharp模板的函数应用程序在新事件进入时运行 . Implementation: 使用https://azure.microsoft.com/en-us/documentation/articles/functions-bindings-event-hubs/中的基本示例 Result: 解释的方法: public static... -
0 votesanswersviews
我可以更改启动检查点的Azure功能事件中心触发器吗?
当我站起来一个新的Azure功能,通过一个新的消费者群体来监听我们的事件中心时,它会获得所有已发送到事件中心的消息,即使是在几个月之前 . 我认为将集线器上的邮件保留设置为一天会限制,但显然不是 . 无论如何,我真的只希望新的Azure功能从初始部署或测试点开始接收事件,但是我不知道如何指定初始启动检查点,因为这些东西在AF存储中神奇地完成了 . 如果我手动执行集线器逻辑,我可以指定此检查点并从任... -
0 votesanswersviews
Azure事件中心失败请求
我正在使用Azure Event Hub . 我们的日志活动将转到我们的活动中心 . 我已经设置了失败请求的警报 . 我一直收到失败的请求 . 我该如何深入研究?我怎么知道是什么导致了这个问题? Azure门户网站只给我一个没用的计数器 . 我启用了诊断日志(它连接到我的存储帐户)但是这个日志再次是一个json并显示我failreq计数和没有详细信息的srvbsy计数 . 所以问题: 如何知道... -
0 votesanswersviews
使用Event Hub out Azure绑定的Azure功能不起作用
我正在使用Azure功能将消息发送到多个事件中心输出(来自输入EH) . 我的代码如下: [FunctionName("Gateway")] public static void Run([EventHubTrigger("%INPUT_HUB_NAME%", Connection = "iothubconnection", Co...