腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
改进
代码
以
根据
最后
一条
消息
日期
从
事件
中心
读取
消息
、
、
、
、
以下
代码
连接到Azure Event Hub,它遍历所有分区,然后
读取
要处理的
消息
并将其插入到数据库中(要完成),
代码
运行良好,但是每次它
读取
所有
消息
。如何将此
代码
改进
为只
读取
未处理的
消息
? 有没有更好的方法来编写while/for部分,你会用不同的方式吗?
浏览 17
提问于2016-08-23
得票数 2
回答已采纳
1
回答
Azure
事件
中心
-同一
事件
中心
中的多个
事件
类型
、
、
、
、
我已经建立了Azure
事件
中心
。有2出版商 问题1:这意味着我们在EH中有不同的信息--这种方法的权衡是什么?我是否应该创建2个EH (一个用于Publisher 1,另一个用于Publisher 2)?如果采用上述方法,则必须设置一个具有侦听策略的消费者,
以
查找这些<em
浏览 3
提问于2017-09-21
得票数 6
1
回答
IoT集线器仅将
消息
路由到
事件
集线器的一个分区
、
、
我在Azure中建立了一个数据管道,在那里我将
消息
发送到IoTHub,然后它将这些
消息
路由到EventHub。当我使用标准的EventProcessorHost方法
从
EventHub中
读取
数据时,我发现只有一个分区被
读取
。我假设实际上只有一个分区将
消息
路由到它。我没有在任何地方指定分区键,并且希望使用循环将
消息
路由到
事件
中心
的所有分区(
根据
https://docs.microsoft.com
浏览 15
提问于2019-03-23
得票数 0
回答已采纳
1
回答
在android上实现http流客户端
、
、
、
、
如何
从
Android发出http post请求,并继续处理服务器发送给我的刷新(使用当前的开放连接)?请注意,响应头包含:Transfer-Encoding:分块1)逐字节
读取
并搜索结束分隔符,一旦获得结束分隔符,我就可以处理
最后
一条
消息
浏览 4
提问于2013-12-17
得票数 2
回答已采纳
1
回答
Azure向EventHub发送日志( WebSocketConnection已选定)。怎么安排呢?
、
、
下面是我通过APIM
从
app服务中
读取
来自eventhub的数据所做的全部设置。 现在我已经知道了这方面的“日志到
事件
”策略,但我的公司并没有使用这种策略。他们要求我按照上面的程序来设置。
浏览 1
提问于2022-06-30
得票数 0
1
回答
Azure服务织物路由
、
、
、
我想得到一些建议,用于设计Azure中的IoT
消息
路由。 我有以下场景:感应器
以
Google格式向Azure IoT集线器发送
消息
。
根据
消息
的类型,我希望将
消息
路由到服务结构中的不同应用程序。我的当前方法是使用服务结构应用程序接收来自IoT集线器的所有
消息
,解析protobuf
消息
,
根据
其类型(protobuf内的属性)将
消息
发送到特定于类型的Azure
事件
中心
。现在,应用程序<e
浏览 0
提问于2017-05-23
得票数 2
回答已采纳
1
回答
Azure IoTHub -如何获取每个设备的使用数据
、
、
我正在使用Azure监视器查看我的IoTHub的诊断/日志。据我所知,在中有deviceDataUsage.,这是连接到此IoTHub的所有设备的总数据使用量。
浏览 18
提问于2020-03-04
得票数 1
回答已采纳
1
回答
从
EventHub
读取
特定
消息
、
、
我想读
一条
来自EventHub的特定信息。partitionId, EventPosition.FromOffset(offset), cancellationSource.Token);我致力于验证
消息
是否在分布式系统中被正确处理。 Source Event Hub -> Processor Function -> Destination Event Hubs.我
读取
了两端(集线器)并验证
消息
到达了它们应该到达的地方
浏览 11
提问于2022-01-19
得票数 2
1
回答
如何
根据
实体的年龄删除特定模板的
消息
实体(
消息
堆栈)
、
对于“私有
消息
”模块,我的Drupal 8站点使用"Message“模块(https://www.drupal.org/project/message)作为子结构。我想在页面中构建一种通知
中心
,它应该可以用
消息
栈来实现(正如我所听到的)。 生成这样
一条
消息
的触发器可能是一个自定义模块。
消息
模块还提供了一种“自动清理”,但不幸的是,据我所见,仅适用于所有
消息
,而不是每个
消息
模板。原则上,我只想要一个通知<
浏览 0
提问于2020-12-05
得票数 0
回答已采纳
2
回答
当向Azure
事件
中心
发送数据时,可以指定
日期
和时间吗?
、
相反,我
从
我的电力公司得到了过去一天的用电数据。具体来说,在过去的一天,我每天都可以在时钟上的每一个小时中得到# kwhs。恐怕是这样的,因为我还没有看到任何
日期
规范,在我可以找到的有限的api文档中。不过,我想确认一下.
浏览 5
提问于2015-06-04
得票数 1
回答已采纳
1
回答
从
历史记录中检索
消息
时获取重复
消息
、
、
、
我
从
Openfire服务器获取历史记录,在加入房间时使用了“自”。下面是我的
代码
:XMPPJID *roomJID,以便下次用户登录时
从
本地获取
最后
一条
消息
日期
,并将其发送到服务器
以
获取该
日期
之后的所有
消息
。但是,当我向服务器发送finalDate时,它会获取我已经存
浏览 14
提问于2016-08-08
得票数 0
1
回答
Azure
事件
中心
消息
保留似乎不起作用
我们在发送给我们的
中心
的
事件
中包括
日期
。每当我将一个新的Azure函数与新的使用者组连接到我们的
事件
集线器时,它似乎会接收发送到集线器的所有
事件
。这在某种程度上是预期的,但是我将
中心
上的
消息
保留设置为1天,因此我预计最多会收到新用户的一天
事件
,但
根据
消息
中的
日期
,它似乎接收到所有
事件
,甚至是几个月前的
事件
,并且比我们在一天内生成的
事件
多得多。<e
浏览 3
提问于2017-11-29
得票数 0
回答已采纳
1
回答
Netty Nio用Java阅读来自ChannelFuture的即将发布的
消息
、
、
、
、
我已经实现了一个JavaFx Gui,并且我想从该Gui
读取
从
服务器或其他客户端接收的
消息
。NettyClient
代码
如下所示:如何使用
从
代码
的其他部分返回的callBack channelFuture来
读取
传入的
消息
?是否需要再次调用callBack,或者如何接收
浏览 1
提问于2017-11-29
得票数 3
1
回答
事件
中心
-避免重复消费,以防出现多个消费者组
、
、
我正在处理一个使用pyspark/python从
事件
中心
读取
事件
的任务。当我有多个消费者组时,我会收到重复的
消息
,这是行为。例如:我有两个消费者小组(CG)和两个活动。CG1消耗event1,当这个过程在第二个
事件
被触发时,CG2将消耗,这很好,但是现在在CG1被释放之后,event1消耗了它的event2,这是我们想要避免的。即使检查点可用,它也会失败。
浏览 14
提问于2021-07-06
得票数 2
1
回答
Databricks Scala :如何流sql select的结果
、
、
、
我需要将数据
从
databricks delta表发送到azure
事件
中心
。数据将使用sql select进行选择。spark.sql("SELECT [columns] FROM table WHERE [where clause]")据我所知,在写作的时候,我需要使用
浏览 0
提问于2020-07-16
得票数 0
1
回答
如何向我的IoT集线器连接字符串添加发送权限?
、
我正在创建一个Azure函数,它需要向Azure IoT集线器发送
消息
。
代码
编译时没有错误,但会生成运行时错误。
浏览 0
提问于2018-04-12
得票数 0
回答已采纳
1
回答
哪些经纪商支持内置的恢复子酒吧丢失的
消息
给崩溃的客户?
、
、
、
在
事件
源场景中,崩溃的
事件
--消费者客户端--应该得到所有漏掉的
事件
--
消息
由源在其关闭时发布。恢复算法(假设它是正确的)将是: 请求服务器(连接2)自给定时间戳(崩溃前)以来丢失的所有
消息
(“错过包”);并在本地应用丢失的
事件
。
从
订阅连接开始
读取
消息
,应用那些时间戳大于
从
丢失包应用的时间戳的
消息
。(在这里,我们假设在订阅和第一次
读取
浏览 1
提问于2016-10-23
得票数 0
回答已采纳
2
回答
使用什么Azure
消息
服务?
、
、
我有一个特定的案例,我想解决使用Azure
消息
服务,但我不确定使用哪一个。有7种选择,我想我已经缩小到了2种选择。Azure服务总线主题 当消耗
事件
的应用程序/均衡器在x时间内下降,然后再次起床
浏览 4
提问于2020-10-19
得票数 1
回答已采纳
4
回答
如何按上次发送时间组织
消息
列表
、
、
、
我正在努力寻找一种
从
mysql表中检索适当结果的适当方法。我有一个用来存储
消息
的表: `id` int(11) NOT NULL AUTO_INCREMENT, `date` datetime NOT NULL,)SELECT * FROM message
浏览 0
提问于2011-11-09
得票数 0
回答已采纳
1
回答
iOS -更改视图在推送通知接收
事件
上的内容
、
、
、
、
据我所知,在发送iOS推送通知时,它会
根据
消息
有效负载自动在通知
中心
为您创建系统通知。搜索完google之后,我想我必须使用应用程序:didReceiveRemoteNotification
事件
来添加/删除视图的内容。我如何访问推送通知的内容,以便我可以将它也放在应用程序中(我想在应用程序中显示
消息
,即使用户已经在通知
中心
拒绝通知)?稍后会有另
一条
消息
(通常是同一天)
从
应用程序中删除
消息
。据我所知,如果应用
浏览 4
提问于2013-08-21
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Java学习Script异步编程实现过程解读
Linux 高级编程-消息队列 MsgQueue
Python之日志处理-logging模块使用教程
Web单线程的终结者:Web Workers
将Kafka作为存储系统
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券