如何使用 Logstash 从 Elasticsearch 获取数据并将其放入 Graphite?

泰尔阿迪贝克

我有logstash.conf文件,我从 MySQL 数据库中获取数据。但是现在我必须从 Elasticsearch 中获取数据并将其放入 Graphite。有一个我的代码logstash.conf

input {
     jdbc {
            type => "some type"
            jdbc_driver_library => "sqljdbc42.jar"
            jdbc_driver_class => "com.microsoft.sqlserver.jdbc.SQLServerDriver"
            jdbc_connection_string => "jdbc:sqlserver://host:port;databaseName=db name"
            jdbc_user =>  "username"
            jdbc_password => "***"
            jdbc_default_timezone => "Asia/Almaty"
            statement_filepath => "sqlscript.sql"
            schedule => "*/30 * * * *"
     }
}

output {

    stdout { codec => json }

    if [type] == "some type"  {

     graphite {
        host => "some host"
        port => port
        metrics => [some.metric", "%{cnt}"]
     }

    }
}

Opster Elasticsearch 专家

您需要做的就是将 logstash.conf 中的输入配置更改为:

elasticsearch {
  hosts => "localhost"
  query => '{ "query": { "match_all": {} }, "sort": [ "_doc" ] }'
}

只需将 elasticsearch 输入用于 logstash

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

如何使用 Logstash 或 curl 向 ElasticSearch 提供数据?

如何使用logstash将Mysql数据迁移到elasticsearch

如何使用logstash将elasticsearch与postgres连接?

如何使用Logstash调整Elasticsearch性能

使用Logstash将数据从Elasticsearch导出到CSV

通过使用scala的logstash将数据批量插入elasticsearch

使用Logstash将数据流式传输到Amazon Elasticsearch?

将Logstash与MySQL和Elasticsearch结合使用,无法发送数据

使用Elasticsearch / Logstash / Kibana的数据库SQL

使用 logstash 将数据集导入 ElasticSearch 很慢

在Elasticsearch中存储解析的数据之前,如何使用Logstash过滤数据

如何在Elasticsearch提示器中使用Logstash导入CSV数据以完成字段类型

如何使用logstash将数组数据类型从mongodb索引到elasticsearch

在使用 logstash 将数据从 MySQL 推送到 Elasticsearch 的同时摄取节点 Elasticsearch

如何运行mongo-kafka连接器作为kafka的源,并将其与logstash输入集成以使用elasticsearch作为接收器?

如何使用AsyncTask从JSON获取数据并将其放入RecyclerView中?

如何使用jQuery从输入中获取数据并将其放入数组中?

如何使用 ReactJS 从 promise 对象获取数据并将其放入 HTML 列表中?

如何测试ElasticSearch Logstash和Kibana

无法在Linux上使用ElasticSearch映射Logstash

使用logstash将文档嵌套到elasticsearch

Logstash不使用Shield写入Elasticsearch

elasticsearch使用logstash和csv删除文档

如何使用logstash在elasticsearch中了解java堆栈跟踪?

Logstash Grokked数据未达到ElasticSearch

如何使用Logstash和jdbc_streaming过滤器将数据从HTTP输入发送到ElasticSearch?

如何使用 logstash+jdbc 和数据库触发器将增量加载到 Elasticsearch

如何从DynamoDB中提取数据并将其插入Elasticsearch

使用Logstash使用单个Elasticsearch Index同步来自两个mysql表的数据