Rabbitmq 플러그인은 ElasticSearch 2.x를

Question

내가 내가 rabbitmq 서버가 다른 시스템 (10.x.x.12)에서 실행이

http://10.x.x.11:9200/

{ 
    "name" : "Everett Thomas", 
    "cluster_name" : "elasticsearch", 
    "version" : { 
    "number" : "2.3.4", 
    "build_hash" : "e455fd0c13dceca8dbbdbb1665d068ae55dabe3f", 
    "build_timestamp" : "2016-06-30T11:24:31Z", 
    "build_snapshot" : false, 
    "lucene_version" : "5.5.0" 
    }, 
    "tagline" : "You Know, for Search" 
} 

우분투 14.04에 탄성 검색 2.3.4을 설치했습니다. 이제는 rabbitmq 서버와 elasticsearch를 연결하여 대기열에 게시 된 모든 메시지가 소모되어 탄성 검색에 삽입되도록하려고합니다.

/etc/logstash/conf.d/rabbit.conf는 오는되지 인해 플러그인 문제 logstash에

rabbitmq { 
    host => "10.x.x.12" 
    queue => "integration" 
    durable => true 
    key => "#" 
    exchange => "integ" 
    threads => 3 
    prefetch_count => 50 
    port => 5672 
    user => "guest" 
    password => "guest" 
} 

가 포함되어 있습니다.

service logstash configtest 
Error: Expected one of #, input, filter, output at line 1, column 1 (byte 1) after {:level=>:error} 

탄성 검색을 위해 플러그인을 설치해야한다고 생각합니다. 이 웹 사이트에서는 탄성 검색> 2.0에서 사용할 수있는 플러그인을 보지 못했습니다.

메시지를 대기열에 게시 할 수 있도록 누군가가 apt 플러그인을 찾는 데 도움을 줄 수 있습니까?

Answer 1

rabbit.conf 파일에 rabbitmq 입력을 input {} 섹션에 추가해야합니다. 또한 elasticsearch 출력과 함께 output{} 섹션이 필요하여 ES 서버에 문서를 보내야합니다.

input { 
    rabbitmq { 
    host => "10.x.x.12" 
    queue => "integration" 
    durable => true 
    key => "#" 
    exchange => "integ" 
    threads => 3 
    prefetch_count => 50 
    port => 5672 
    user => "guest" 
    password => "guest" 
    } 
} 
output { 
    elasticsearch { 
     hosts => ["10.x.x.11:9200"] 
     index => "your_index" 
     document_type => "your_type" 
    } 
}