`
kabike
  • 浏览: 610750 次
  • 性别: Icon_minigender_1
  • 来自: 大连
社区版块
存档分类
最新评论

storm中添加自定义metrics

 
阅读更多
storm中有时需要添加一些metrics监控项,这时需要添加metrics.
在spout或者bolt的prepare方法中注册metrics
	public void prepare(@SuppressWarnings("rawtypes") Map stormConf,
			TopologyContext context, OutputCollector collector) {
		this.collector = collector;
		barMetric = new CountMetric();
		context.registerMetric("bar", this.barMetric, 3);
	}

在恰当的时候更新metrics
	public void execute(Tuple input) {
		if (input.getSourceComponent().equals("bar")) {
			barMetric.incr();
		}
		collector.ack(input);
	}

启动拓扑的时候注册metrics的consumer
conf.registerMetricsConsumer(MetricsConsumer.class);
分享到:
评论

相关推荐

    storm-metrics-reporter:Storm指标报告器模块

    风暴指标报告者 一个Storm指标报告器,能够将Storm内置指标和自定义指标... 上面的屏幕截图是使用自定义StormMetricProcessor实现生成的,而不是源代码中包含的实现。 它描述了一种特定的Graphite命名约定(例如,主机

    spark-metrics:Spark指标相关的自定义类和接收器(例如Prometheus)

    这是与ApacheSpark指标相关的自定义类(例如源,接收器)的存储库。 我们试图用Prometheus接收器扩展Spark Metrics子系统,但没有在上游合并。 为了支持其他人使用Prometheus,我们将接收器外部化并通过此存储库提供...

    keras库文件,在loss和metrics库文件中添加rmse方法

    在keras的loss库中添加rmse方法,成功使模型能正常使用rmse方法。在metrics.py文件上添加rmse方法后可以使用model.compile(loss='mse',weighted_metrics=['rmse'])方法,可以在其他loss的条件下观测rmse的变化

    metrics-scraper_1_0_6.tar.gz

    - **自定义指标**:允许用户添加自定义的指标源和度量,扩展性强。 - **安全性**:使用Kubernetes的ServiceAccount和RBAC策略,确保安全访问集群资源。 5. **使用场景** - **性能分析**:监控Pod和Node的资源...

    Laravel开发-laravel-metrics

    接着,你需要在`config/app.php`中的`providers`数组中添加`Spatie\LaravelMetrics\MetricsServiceProvider::class`。配置文件`config/metrics.php`允许你定义和定制你要展示的指标。 2. **创建指标** Laravel ...

    metrics-3.1.3-release

    9. **代码示例**:在"metrics-3.1.3-release"中,你可以找到示例代码和文档,帮助你理解如何在项目中使用Metrics。通过这些示例,你可以学习如何创建度量、注册它们、配置Reporter以及如何进行自定义扩展。 10. **...

    storm-graphite-metrics:将指标导出到石墨中的 Storm 的指标消费者

    #storm-graphite-metrics Apache Storm 的度量消费者,它使用 Storm 的度量消费者接口将度量从 Storm 导出到石墨中。 ##Usage 在 Storm 配置中 conf . registerMetricsConsumer( GraphiteMetricsConsumer . class,...

    Metrics3.0集成SpringMVC

    集成Metrics3.0到SpringMVC项目中,首先需要在项目的pom.xml文件中引入Metrics3.0的Spring支持依赖,例如`metrics-spring`库: ```xml <groupId>io.dropwizard.metrics <artifactId>metrics-spring <version>3....

    yammer metrics-2.2.0 源码

    11. **Instrumentation**:yammer metrics提供了丰富的API,使得开发者可以轻松地在代码中添加性能监控。例如,通过`@Timed`、`@Metered`和`@Counted`注解,可以自动收集方法的执行时间、调用次数等信息。 12. **...

    Laravel开发-metrics

    安装Laravel Metrics通常通过Composer完成,使用`composer require`命令添加依赖。然后,在配置文件中进行必要的设置,例如指定哪些度量应该被收集以及如何展示这些数据。 3. **度量类与注册** 在Laravel中,度量...

    使用 prometheus python 库编写自定义指标的方法(完整代码)

    通过为每个指标指定合适的名称和描述,以及在需要的时候调用对应的更新方法(如 `inc`、`set`、`observe`),你可以轻松地将自定义的监控数据集成到 Prometheus 系统中,进一步完善你的监控解决方案。

    Kubernetes部署kube-state-metrics

    Kubernetes是目前最流行的容器编排系统,而kube-state-metrics是Kubernetes生态系统中的一个关键组件,它负责收集集群状态的度量数据。本篇文章将深入探讨如何在Kubernetes上部署kube-state-metrics以及这个组件的...

    48 _ Prometheus、Metrics Server与Kubernetes监控体系1

    3. **应用程序自定义Metrics**:应用程序可以使用自定义Metrics API或其他支持Prometheus格式的库来报告其特定的业务逻辑指标。 Metrics Server是另一个在Kubernetes中用于收集Pod和Node资源使用情况的重要组件,它...

    metrics-jvm-3.1.5-API文档-中文版.zip

    赠送jar包:metrics-jvm-3.1.5.jar; 赠送原API文档:metrics-jvm-3.1.5-javadoc.jar; 赠送源代码:metrics-jvm-3.1.5-sources.jar;...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。

    piggymetrics-master_DEMO_PiggyMetrics微服务_

    4. **服务间通信**:在PiggyMetrics中,服务之间的通信主要通过Ribbon和Feign实现。Ribbon是客户端负载均衡器,而Feign则是一个声明式Web服务客户端,使得服务调用更加简洁。 5. **API Gateway**:PiggyMetrics使用...

    Python库 | keras_metrics-0.0.5-py2.py3-none-any.whl

    在本文中,我们将深入探讨`keras_metrics-0.0.5-py2.py3-none-any.whl`这个Python库,了解它的核心功能、安装与使用方法,以及它在实际项目中的应用。 首先,`keras_metrics`库是专门为Keras设计的一套自定义损失...

    49 Custom Metrics 让Auto Scaling不再“食之无味”.pdf

    具体来说,当用户访问这个自定义监控URL时,CustomMetrics API Server会查询Prometheus中相应的指标值,然后按照约定的格式返回。 为了收集到这些监控指标,Pod中的应用程序通常需要暴露出/metrics的API端点,用于...

    K8S1.20.6资源对象监控kube-state-metrics-2.0.0镜像及资源清单文件

    配置项可以通过`data`字段添加到ConfigMap中。 4. **ServiceAccount**: 用于`kube-state-metrics` pod的身份认证和授权,确保它可以访问需要监控的资源对象。 5. **Role和RoleBinding**: 定义权限规则,允许`kube-...

    metrics-core-4.2.7.jar中文-英文对照文档.zip

    注:下文中的 *** 代表文件名中的组件名称。 # 包含: 中文-英文对照文档:【***-javadoc-API文档-中文(简体)-英语-对照版.zip】 jar包下载地址:【***.jar下载地址(官方地址+国内镜像地址).txt】 Maven依赖:【*...

    metrics-core-4.2.7-API文档-中文版.zip

    赠送jar包:metrics-core-4.2.7.jar; 赠送原API文档:metrics-core-4.2.7-javadoc.jar; 赠送源代码:metrics-core-4.2.7-sources.jar;...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。

Global site tag (gtag.js) - Google Analytics