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插件参数
参数名 | 类型 | 默认值 | 说明 |
host | string | rabbitmq服务器地址 | |
port | number | 5672 | 端口 |
user | string | guest | RabbitMQ 账号 |
password | string | guest | RabbitMQ 密码 |
queue | string | 队列名 | |
auto_delete | boolean | false | 最后一个消费组退出后是否删除消息 |
prefetch_count | number | 256 | 预加载多少条消息到本地 |