腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
关于
akka
流
的
聚合
指标
scala
、
stream
、
akka
、
metrics
在我
的
应用程序中,我有一个多路复用
的
源,用于客户端调用。 类似于: val source: RunnableGraph[Source[...]] = ...如果我有上千个客户端每秒调用foo和foo ticks,那么就会有数百万条毫无意义
的
日志消息。因此,我想去掉上面的单个日志,并用一条
聚合
消息替换它,如下所示: “将某些内容发送到X客户端”。我已经看过Kamon和cinnamon了,所以我很欣赏它们可能是可以做
的
,但理想情况下,像这样
的
东西有更轻量级
的
东西?
浏览 9
提问于2019-05-02
得票数 1
1
回答
在Reactor中有没有等同于
Akka
Streams
的
`conflate`和/或`batch`运算符?
project-reactor
我正在寻找项目反应堆中
Akka
Streams中
的
<code>C0</code>和<code>C1</code>操作符
的
等价物,或者模仿其行为
的
操作符
的
某种组合。这个想法是当下游背压时,以<code>D2</code>-like
的
方式
聚合
上游项目。请注意,这不同于<code>C3</code>,因为这里描述
的
<c
浏览 11
提问于2019-08-20
得票数 2
2
回答
跨各种属性
聚合
的
最佳技术栈
hadoop
、
amazon-web-services
、
amazon-s3
、
amazon-redshift
、
elastic-map-reduce
我们正在开发一个平台,对跨图
的
实体流进行建模。系统必须回答这样
的
问题:有多少个具有这些属性
的
实体坐在图上
的
给定节点上,节点上
的
流入是什么,节点上
的
流出是什么。
流
数据被输入到
流
中
的
系统。我们正在考虑打破时间桶(例如5分钟)中
的
流
数据,并根据不同
的
属性预计算各种
聚合
,并将
聚合
存储在DynamoDB中以服务查询。
关于
这一点,我们正在评
浏览 4
提问于2013-03-13
得票数 0
回答已采纳
1
回答
Akka
-streams:如何在kamon-
akka
报告
的
指标
中获取
流
名称
scala
、
akka-stream
、
akka-monitoring
、
kamon
我一直在尝试为
Akka
streams设置一些工具。让它正常工作,但是,即使我命名了所有属于
流
的
流
,我仍然在
指标
中得到这样
的
名称:flow-0-0-unknown-operationval myflow = Flow[String].named("myflow").map(println) 我基本上想要查看为&quo
浏览 12
提问于2016-11-25
得票数 10
1
回答
如何分析
Akka
Java应用程序邮箱
java
、
profiling
、
akka
、
typesafe
如何分析基于Java
的
Akka
应用程序?我看了
的
答案。而另一个则将您重定向回 我们在基于
Akka
-Java
的
应用程序中遇到了性能问题,我们想要确定这是否是我们建模我们
的
参与者层次结构
的
方法中
的
一个问题例如,我们如何对应用程序进行分析,以便在任何给定
的
时间点看到在任何参与者<
浏览 2
提问于2014-05-28
得票数 1
0
回答
Akka
stream从外部世界获取无穷大流的当前值
akka
、
akka-stream
获取无限流的当前值
的
最佳方法是什么,该无限流
聚合
了值,并且根据定义永远不会完成 .scan(0)(_+_)我想从
Akka
HTTP我应该使用动态
流
吗?该broadcastHub,然后从
Akka
http订阅无限流
的
GET请求?
浏览 6
提问于2017-12-07
得票数 0
回答已采纳
1
回答
用于Spark结构化流媒体
的
Grafana
apache-spark
、
grafana
、
prometheus
、
spark-structured-streaming
我按照以下步骤设置了Prometheus、Graphite Exporter和Grafana,以绘制运行结构化
流
的
Spark 2.2.1
的
指标
。这篇文章
的
收集
指标
非常过时;并且不包括任何可以用来监控结构化流媒体
的
指标
(我相信)。我对执行执行各种
聚合
的
流
查询
的
资源和持续时间特别感兴趣。有没有任何预配置
的
Spark仪表板--我有点惊讶在上没有找到,这让我怀疑Grafa
浏览 2
提问于2018-02-03
得票数 2
1
回答
反应性
流
Kafka
流
扇向http演员输出
microservices
、
akka-http
、
akka-stream
、
apache-kafka-streams
、
reactive-streams
我对
Akka
流
和反应
流
非常陌生。我有一个问题:是否有可能让rest接收一条消息,将其丢弃在Kafka总线上,然后由Kafka流用户最大限度地
聚合
消息。回溯答案
的
时间窗口吗? 如何实施这样
的
制度?
浏览 1
提问于2017-05-25
得票数 0
回答已采纳
2
回答
如何对参与者集合执行查询
akka
、
akka.net
这些参与者
的
状态是持久化
的
Akka
.Persistance。现在我们要为这个参与者系统构建查询系统。基本上,我们
的
问题是,我们希望有一种方法来获得这些特定参与者
的
所有状态
的
汇总/列表。虽然我没有严格地订阅CQRS模式,但我认为这可能是一种很好
的
方式。 我最初
的
想法是有一个参与者来查询,作为其状态
的
一部分,它包含正在执行“数据写入”
的
其他参与者
的
状态
的
聚合
浏览 2
提问于2017-01-26
得票数 4
回答已采纳
1
回答
在cloudwatch中更改单元类型不会做任何事情
amazon-web-services
、
amazon-cloudwatch
一开始,我是这样发送我
的
指标
的:
指标
仍然出现在同一张图上我认为cloudwatch按单元
聚合
指标
,这是为了创建一个新
的
浏览 7
提问于2018-01-29
得票数 0
回答已采纳
1
回答
Flink如何扩展热分区?
join
、
streaming
、
apache-flink
、
flink-streaming
如果我有一个用例,我需要连接两个
流
或
聚合
来自单个
流
的
某种
指标
,并且我使用键控
流
对事件进行分区,那么对于数据可能无法放入内存并需要跨分区拆分
的
热分区,Flink如何处理这些操作?
浏览 17
提问于2021-02-19
得票数 0
回答已采纳
2
回答
Akka
Streams +
Akka
集群
java
、
akka
、
akka-stream
、
akka-cluster
我有一个
关于
使用
Akka
Streams和
Akka
集群
的
问题。我正在尝试做一个使用
Akka
Streams和
Akka
Cluster
的
分布式字数统计版本。我想构建一个
Akka
Streams客户端,它将文本文件作为
流
I/O读取,并将单词
流
发送到远程集群。这是客户端
的
代码:final
浏览 5
提问于2018-11-10
得票数 2
1
回答
如何
聚合
普罗米修斯
指标
aggregation
、
metrics
、
prometheus
我
的
各种docker容器导出prometheus
指标
,但是我们
的
prometheus安装只需要从一个端点提取所有
指标
。不幸
的
是,这是不能改变
的
。因此,我需要从prometheus安装可以抓取
指标
的一个点
聚合
所有
指标
。 此外,如果这个程序或脚本能够提供
关于
如何处理由不同端点导出
的
相同
指标
的额外逻辑,那就太好了。例如,如果我只是将不同
的
指标
站点连接在
浏览 3
提问于2018-01-31
得票数 3
1
回答
仅使用kamon
Akka
HTTP工具
scala
、
akka-http
、
kamon
我想使用kamon-
akka
- http,目前我
的
项目有包含Kamon
akka
http
的
kamon包依赖项。问题是我从捆绑包中
的
所有其他工具(
Akka
Instrumentation、
Akka
Remote Instrumentation、Executor Service Instrumentation、Logbackinstrumentation和Scala Future Instrumentation)收到了许多其他
指标
。我只想接收<em
浏览 22
提问于2020-04-22
得票数 0
2
回答
Flink度量名称冲突
scala
、
apache-flink
、
flink-streaming
我
的
Flink (1.6)作业监听一个
流
并执行一些
聚合
。我想在
聚合
之后收集
指标
,但遇到了一些困难。我
的
指标
如下所示:id_2, 0.3it将是可变
的
,并且值将随着时间
的
推移而增加和减少,因此看起来是最合适
的
。我创建了这个map函数来捕获仪表中
的
这些
指标
: class MetricsMapper extends RichMapFunction[MyOb
浏览 0
提问于2018-10-30
得票数 0
2
回答
akka
-具有
akka
集群
的
流
scala
、
akka
、
akka-cluster
、
akka-stream
我
的
阿克卡
流
继续学习。我想将我
的
akka
应用程序与集成。 case ChatClient.Message(from, text) => }我
的
问题是,我应该如何将这个角色集成到我
的
流
中,以及如何确保在没有
流
背压<em
浏览 6
提问于2016-02-03
得票数 4
回答已采纳
1
回答
关于
Akka
消息传输性能:多个小消息还是少一些大消息?
performance
、
networking
、
akka
、
message-passing
对于我目前正在使用
Akka
开发
的
数据挖掘算法,我想知道
Akka
是否实现了发送
的
消息
的
性能优化。或者
Akka
本身就有某种缓冲器,使得不是一条消息,而是多条消息同时在网络上传输? 我之所以问这个问题,是因为算法应该在传输性能很重要
的
集群上远程执行,而我目前没有选择只做基准测试。
浏览 1
提问于2013-08-01
得票数 3
回答已采纳
3
回答
使用
Akka
/
Akka
流
/
Akka
HTTP时
的
冲突
Akka
版本
scala
、
sbt
、
akka
、
akka-stream
、
akka-http
" %% "
akka
-http-core" % "10.0.9",但是,我一直收到
关于
版本conflicts...It
的
以下警告:
akka
-http对
Akka
/ Streams版本2.4.19具有传递依赖关系。我最近发现了一个类似的,它建议显式地添加
akka
浏览 4
提问于2017-08-29
得票数 4
回答已采纳
1
回答
演员统计数据没有从卡蒙发送到StatsD
akka-http
、
akka-monitoring
、
kamon
我可以在Graphana和Graphite以及JVM和OS统计中看到我
的
自定义计数器数据,但是没有来自
Akka
的
参与者统计数据。我
的
项目设置就像一样,但是我增加了Kamon
的
东西和我自己
的
HttpService。我遗漏了什么?这是我
的
配置: trace.level = simple-trace tick-interval = 1 second
浏览 5
提问于2016-12-08
得票数 1
回答已采纳
1
回答
Akka
.net持久化查询-Events
的
标签
流
顺序保证
akka.net
、
akka.net-persistence
、
akka.net-streams
我正在使用
Akka
.net构建一个解决方案,该解决方案将允许查询多个标记
的
持久性查询。我认为这样做
的
方法之一是简单地为每个标记物化一个
流
,然后使用
akka
.net
流
抽象将
流
与顺序合并。但是,Getakka.net ()
关于
日志可能提供
的
预定义查询
的
指南表明,获取多个PersistenceIds
的
查询没有排序保证。我想知道,这是因为
akka
.net leaves会阅读日志实现到单个插
浏览 2
提问于2022-07-24
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
关于增加生物毒性检测指标疑问的回复
壹明文化:收好这些关于信息流短视频的小知识!
携程新一代监控告警平台Hickwall架构演进
使用DDD、事件风暴和Actor来设计反应式系统
Akka Actor及其在商业智能数据服务中的应用
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券