Elasticsearch的ActiveMQ河配置

我開始配置ActiveMQ的河流，我已經安裝了（ActiveMQ plugin），但我感到困惑如何使它工作，該文檔是如此的短暫，其實，我按照創建的完全步驟一條新河，但我不知道下面的步驟要遵循什麼？Elasticsearch的ActiveMQ河配置

注：

我有一個ActiveMQ的服務器啓動和運行，我使用簡單JMS應用推消息放入隊列中進行了測試。

我創建使用新河：

curl -XPUT 'localhost:9200/_river/myindex_river/_meta' -d '{ 
    "type" : "activemq", 
    "activemq" : { 
     "user" : "guest", 
     "pass" : "guest", 
     "brokerUrl" : "failover://tcp://localhost:61616", 
     "sourceType" : "queue", 
     "sourceName" : "elasticsearch", 
     "consumerName" : "activemq_elasticsearch_river_myindex_river", 
     "durable" : false, 
     "filter" : "" 
    }, 
    "index" : { 
     "bulk_size" : 100, 
     "bulk_timeout" : "10ms" 
    } 
}'

創建先前河後，我能得到它的使用 curl -XGET 'localhost:9200/my_index/_status'狀態，它給我的指標狀態，而不是創建河流。

請幫助我通過使用elasticsearch獲得ActiveMQ河流配置的正確道路。

來源

2013-04-16 user2286856

我告訴你在郵件列表中。定義index.index值，或者設置一條河的名字是你的索引名（容易）：

curl -XPUT 'localhost:9200/_river/my_index/_meta' -d ' 
{ 
    "type":"activemq", 
    "activemq":{ 
    "user":"guest", 
    "pass":"guest", 
    "brokerUrl":"failover://tcp://localhost:61616", 
    "sourceType":"queue", 
    "sourceName":"elasticsearch", 
    "consumerName":"activemq_elasticsearch_river_myindex_river", 
    "durable":false, 
    "filter":"" 
    }, 
    "index":{ 
    "bulk_size":100, 
    "bulk_timeout":"10ms" 
    } 
}'

或

curl -XPUT 'localhost:9200/_river/myindex_river/_meta' -d ' 
{ 
    "type":"activemq", 
    "activemq":{ 
    "user":"guest", 
    "pass":"guest", 
    "brokerUrl":"failover://tcp://localhost:61616", 
    "sourceType":"queue", 
    "sourceName":"elasticsearch", 
    "consumerName":"activemq_elasticsearch_river_myindex_river", 
    "durable":false, 
    "filter":"" 
    }, 
    "index":{ 
    "index":"my_index", 
    "bulk_size":100, 
    "bulk_timeout":"10ms" 
    } 
}'

它應該幫助。

如果不是，憑什麼你可以在日誌中看到更新的問題。

來源

2013-04-16 17:24:00 dadoonet

Elasticsearch的ActiveMQ河配置

回答

相關問題