0

ActiveMQ リバーの構成を開始しました。( ActiveMQ プラグイン) は既にインストールされていますが、それを機能させる方法について混乱しています。ドキュメントは非常に簡単でした。実際には、新しいリバーを作成する手順に正確に従いますが、次の手順がわかりませんか?

ノート：

  1. ActiveMQ サーバーを稼働させ、単純な JMS アプリを使用してメッセージをキューにプッシュすることをテストしました。

  2. 以下を使用して新しい川を作成しました。

    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"
  }
}'

  3. 前の川を作成した後、 を使用し curl -XGET 'localhost:9200/my_index/_status'てそのステータスを取得できました。作成された川ではなく、インデックスのステータスが表示されます。

エラスティックサーチを使用したActiveMQリバー構成で正しい道を歩むために助けてください。

4

1 に答える 1

1

メーリングリストでお伝えしました。値を定義する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-16T17:24:00.303 に答える