redis - logstash - influxdb 数据传输

Question

我有一个 redis 数据库、logstash 和两个 elasticsearch 和一个 influxdb。我正在将 key 从 redis 传输到 elasticsearch，它工作正常并且想测试根本不起作用的 influxdb。

有人有有效的 influxdb 连接器吗？或者我应该如何在 redis 中提供数据以使其正常工作？

这是我的 influx-db 连接，只会引发错误

  influxdb {
        host => "localhost"
        measurement => "sensor1"
        allow_time_override => true
        use_event_fields_for_data_points => true
        exclude_fields => ["@version", "@timestamp", "sequence", "type", "host"]

    }

这是我的 redis 连接，工作正常

redis
{
		host => "localhost"
		data_type => "list"
		key => "vortex"
		threads => 4
		type => "testrecord"
		codec => "plain"
}

我试过这种行格式

“传感器1，测量=1 1489594615.9747”作为 redis 的列表，例如

key: vortex

values:
sensor1,measure=1 1489594615.9747
sensor1,measure=1 1489594615.9747
sensor1,measure=1 1489594615.9747
sensor1,measure=1 1489594615.9747
sensor1,measure=1 1489594615.9747
....

但这也行不通。

有人知道如何通过 logstash 从 redis 获取数据到 influxdb 吗？

Answer 1

搜索了几个小时后，我通过以下方式解决了它:

• 首先进入 logstash 文件夹中安装的 influxdb 插件版本，例如C:\tools\logstash-5.2.2\vendor\bundle\jruby\1.9\gems\logstash-output-influxdb-4.0.0\lib\logstash\outputs
• 搜索文件 influxdb.rb(应该是文件夹中的唯一文件)

• 替换保留策略

  要使用的保留策略

• config :retention_policy, :validate => :string, :default => "autogen"

• //config :retention_policy, :validate => :string, :default => "default"<< orignial

  • 在 redis 中我使用了以下字符串格式(没有时间戳)foo=70617 bar=3

  • logsash 的配置文件如下所示 - 只是作为一个示例，说明如何最终运行 :-)

input {

		 
 	redis{
		host => "localhost"
		data_type => "list"
		key => "vortex"
		threads => 4
		type => "testrecord"
		codec => "plain"

	}
	}

filter {
           kv {
              add_field => {
                "test1" => "yellow=cat"
                "test=space" => "making= life=hard"
                "feild= space" => "pink= dog"
              }
           }
}

output {

	stdout { codec => rubydebug }

           influxdb {
             host => "localhost"
             measurement => "myseries"
             allow_time_override => true
             use_event_fields_for_data_points => true
             exclude_fields => ["@version", "@timestamp", "sequence", "message", "type", "host"]
             send_as_tags => ["bar", "baz", "test1", "test=space"]
		}
      }