腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
使用
Reactive
X
streams
处理
来自
事件
中心
的
数据
、
、
、
我想
使用
Rx .net扩展来
处理
来自
Azure Event Hub
的
事件
。 如何根据从EventProcessorHost获得
的
消息创建可观察流?我没有找到这个场景
的
参考资料,我是不是遗漏了什么基本
的
东西?我是不是在尝试做一些没有意义
的
事情?
浏览 57
提问于2018-01-31
得票数 0
回答已采纳
1
回答
了解Akka如何提供背压
、
、
、
、
因此,我们在我们
的
生产系统中有一个用例,我们可能会
使用
Akka
streams
。为了了解Akka
streams
究竟是如何提供背压
的
,我想更深入地了解我们
的
需求。我们有一个托管部分
数据
的
Solr集群。接下来,我们有一个Play应用程序,它服务于面向客户
的
前端站点。每个传入
的
请求最终归结为
使用
Solr提供
的
/sql
处理
程序从Solr获取大量
数据</
浏览 18
提问于2020-09-20
得票数 0
3
回答
Java Spring WebFlux vs RxJava
、
、
、
我开始学习Java
的
反应式编程。整个反应式范式对我来说都是新
的
。我读到Spring实际上在内部
使用
了WebFlux
的
Flux/Mono。这将问题简化为Spring Webflux在RxJava上
的
利弊?
浏览 2
提问于2019-06-05
得票数 33
回答已采纳
1
回答
反应性编程和流
处理
引擎之间
的
关系是什么?
、
、
、
与像Storm和Flink这样
的
流
处理
引擎相比,我什么时候会
使用
像RX和Project反应堆这样
的
反应式编程库呢?
Reactive
是一个更低层次
的
概念,因为它可以实现流
处理
引擎。我认为Akka
Streams
浏览 0
提问于2020-03-01
得票数 0
1
回答
Azure :如何根据标准从
事件
中心
处理
Azure日志
事件
并进行筛选
、
、
、
、
如何从
事件
中心
处理
Azure日志
事件
,并根据标准进行筛选。在较高
的
水平上,流程如下所示。源
来
浏览 0
提问于2020-03-19
得票数 1
1
回答
将Akka与apache spark streaming和Kafka一起
使用
?
、
、
下面是我正在尝试
的
高级用例。我们有发布到Kafka主题
的
学生
数据
流,我们
的
模块必须以流
的
形式读取学生ids,并从多个来源获取每个学生
的
关联
数据
,然后为每个学生执行一些计算,并将每个学生
的
关联计算发布到kafka主题中。因此,这里
的
问题是更好地编写一个大
的
Spark作业或
使用
Akka为每个源提供单独
的
服务,以便参与者可以并行工作,获取一堆学生it,并从各自
的
源获取<
浏览 2
提问于2017-07-14
得票数 1
1
回答
Azure Event Hub日志排序
使用
查询流式
处理
、
、
、
、
如何
处理
来自
事件
中心
的
Azure日志
事件
并根据条件进行筛选。 我们正在尝试筛选特定
的
关键或与安全相关
的
诊断和活动日志,然后再输入我们
的
Onprem SIEM解决方案。有没有人可以指导我如何从
事件
中心
过滤
数据
,然后重新摄取到另一个
事件
中心
。这是否可能,或者是否有任何其他可用
的
替代方案。 在较高
的
级别,流程如下所示
浏览 21
提问于2020-03-19
得票数 1
1
回答
反应堆,未能装载"org.slf4j.impl.StaticLoggerBinder“级
、
、
我已经开始玩反应堆了,但我
的
第一件事有麻烦了。有什么问题吗?
浏览 4
提问于2014-09-13
得票数 1
回答已采纳
1
回答
为什么Observable.Generate()抛出System.StackOverflowException?
、
、
、
我正在编写一个C# (.NET 4.5)应用程序,用于聚合基于时间
的
事件
以用于报告目的。为了使我
的
查询逻辑可重用于实时
数据
和历史
数据
,我
使用
了反应式扩展(2.0)和它们
的
IScheduler基础设施(HistoricalScheduler和朋友)。System.
Reactive
.Disposables.AnonymousDisposable.Dispose() + 0
x
4d bytes System.
Reactive<
浏览 0
提问于2012-11-20
得票数 10
回答已采纳
1
回答
使用
pyspark - Databricks
处理
来自
事件
中心
的
事件
、
、
、
我有一个Mongo change流(一个pymongo应用程序),它不断地获取集合中
的
更改。这些由程序接收
的
更改文档将发送到Azure
事件
中心
。如果文档中
的
字段少于表中
的
字段,则必须
使用
Null添加列。 我正在从Event Hub读取
事件
,如下所示。如果我可以将流式
数据
帧中
的
JSON字符串转换为可以由
数据
帧推断其模式
的
JSON对象(就像read.json所做
的
那样
浏览 1
提问于2019-01-12
得票数 0
1
回答
事件
集线器触发器超时
、
、
我正在
使用
来自
事件
中心
的
事件
中心
触发器并
处理
它们,现在当它们被触发时,
处理
如此多
的
事件
会导致
事件
中心
触发器超时。我是否可以在
事件
集线器触发器中获得功能,以便在接收到一批
事件
后停止它,并自行重新启动以绕过超时(我无法以某种方式增加超时)?
浏览 4
提问于2021-09-13
得票数 0
1
回答
使用
反应性香蕉中
的
数据
设置自定义
事件
、
、
我有一个样本,我从
reactive
-banana回购。它
使用
gloss。但是当我
处理
事件
时,我有自己
的
事件
和
数据
。这些
事件
不一定是UI
事件
。所以我希望玻璃钢能帮助我对定制
事件
进行编码。因此,例如,列表可能会更改,更改后
的
数据
在
事件
中,应用程序
的
另一部分
使用
更改
的
数据
。我
的
初步
浏览 12
提问于2022-08-13
得票数 0
回答已采纳
1
回答
是否有任何方法将
数据
从AWS Kinesis发送到Azure
事件
中心
?
、
、
、
、
我
的
公司正在对一些流
数据
进行POC,其中一项任务是将
数据
从AWS Kinesis发送到Azure
事件
中心
。 以前有人试过做这种事吗?我在想一个lambda功能,听着动感消防水管,并将
数据
发送到
事件
中心
,但我对Azure一点经验都没有,我甚至不知道这是否可能。
浏览 3
提问于2022-03-14
得票数 0
回答已采纳
1
回答
为
数据
库提供反应式api
、
、
、
、
如何为不支持流式
处理
的
数据
库提供reactivestreams api?比如,比如说dynamodb。当执行get调用时,dynamodb将返回所有结果。因此,即使我将get调用包装在一个Source中,我如何
处理
来自
下游阶段
的
背压?另外,我如何在db中实现写调用?我
的
水槽会是什么样子?任何关于这方面的建议都会很有帮助。
浏览 0
提问于2016-10-04
得票数 1
1
回答
是否可能跟踪ERC721
的
市场销售情况?
、
、
、
、
我知道我可以跟踪智能合同
的
事件
,比如Transfer和Approval ( ERC20和ERC721 ),甚至ApprovalForAll ( ERC721 )。我还知道,对于我部署
的
任何智能契约,我都可以跟踪自己定义
的
事件
。当用户将他/她
的
令牌传输给它时(
使用
Transf
浏览 0
提问于2023-03-17
得票数 2
回答已采纳
1
回答
闪亮
的
“切换
数据
集”不工作。只有一个
数据
集正在加载
、
、
我想创建一个闪亮
的
应用程序,用户可以查看
来自
两个不同
数据
集
的
数据
:“新
的
”和“
中心
的
”。我
使用
以下代码:fluidPage()) # Define UI for applica
浏览 0
提问于2018-01-27
得票数 2
1
回答
Azure函数输出到EventHub
、
、
我有一个用NodeJS构建
的
Azure函数,它在HTTP触发器上接收
数据
,
处理
数据
,然后将
处理
过
的
数据
输出到Azure
事件
中心
,以便在Azure ADX中摄取。输出
数据
是JSON格式
的
有效负载。流动:
使用
EventHubProducerClient类(
来自</
浏览 8
提问于2022-07-01
得票数 0
1
回答
使用
可裁剪
的
ReactiveMongo扩展Spring WebFlux
、
、
、
我正在构建一个服务器发送
事件
端点,该端点将在很长一段时间内保持打开
的
连接(1h+),实时连续发送
事件
。我
使用
reactive
Mongo在所有应用程序实例之间共享所有
数据
库更新。据我所见,每个HTTP请求都打开了一个新
的
Mongo连接。这是不可行
的
,因为DB连接池是有限
的
。
使用
默认值在500个http请求(500个打开
的
SSE http连接=> 500个
数据
库连接)时开始崩溃
浏览 13
提问于2020-04-08
得票数 0
回答已采纳
2
回答
哈泽尔卡斯特喷气机中
的
StreamSource与BatchStage
、
、
我在申请疾病预防控制
中心
。1]
使用
cdc捕获db更改并将其存储在地图中。这是我
的
密码。pipeline.readFrom(Sources.map("mapStore")).writeTo(Sinks.logge
浏览 4
提问于2021-10-16
得票数 0
1
回答
无法正确理解
事件
中心
消费者组是如何工作
的
、
Requirement I希望并行
处理
来自
多个
使用
者
的
事件
数据
(相同
数据
)我从文档中了解到如何
处理
相同
的
数据
表单
事件
中心
,我们需要创建多个
使用
者组。
使用
者组允许多个消费应用程序对每个
事件
流有一个单独
的
视图,并以自己
的
速度和自己
的
偏移量独立地读取该流。消息保留1,分
浏览 0
提问于2018-04-30
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring Boot 中的响应式编程和 WebFlux 入门
Spring Boot 2.0-WebFlux framework
浅谈java响应式编程以及Reactor 3框架
使用 Kotlin+WebFlux/RxJava 2 实现响应式以及尝试正式版本的协程
Flux 会取代 Web MVC 或可不再基于 Servlet 容器了?
热门
标签
更多标签
云服务器
ICP备案
实时音视频
云直播
对象存储
活动推荐
运营活动
广告
关闭
领券