一架梯子,一头程序猿,仰望星空!

Logstash RabbitMQ input插件


RabbitMQ input插件,支持Logstash通过RabbitMQ消息队列读取数据。

例子:

input {
  # 配置rabbitmq数据源
  rabbitmq {
    # rabbitmq服务器地址
    host => "localhost"
    # 端口  
    port => 5672
    # RabbitMQ 账号
    user => "guest"
    # RabbitMQ 密码
    password => "guest"
    # 队列名
    queue => "tizi365"
  }
}

output {
  elasticsearch {
    hosts => ["http://localhost:9200"]
    index => "tizi365" 
  }
}

RabbitMQ Input插件参数

参数名类型默认值说明
hoststringrabbitmq服务器地址
portnumber5672端口
userstringguestRabbitMQ 账号
passwordstringguestRabbitMQ 密码
queuestring队列名
auto_deletebooleanfalse最后一个消费组退出后是否删除消息
prefetch_countnumber256预加载多少条消息到本地