2

Elasticsearch で比較的複雑な Scala オブジェクトのインデックスを作成しようとしています。これが私のケースクラスです：

case class Game(id: Int,
            gameStates: Seq[GameState],
            playerActions: Map[String, PlayerAction],
            gameActions: Map[String, GameAction],
            endGame: EndGame)
case class GameState(players: Seq[Player])
case class Player(id: Int, deck: Seq[Card], playSpace: Seq[Card])
case class Card (rank: Int, suit: String) extends Ordered[Card]

これらのケース クラスごとに、次のスタイルの Format[ObjectType] writes メソッドの定義を含むコンパニオン オブジェクトがあります。

object Game {
  implicit object GameFormat extends Format[Game] {
    def writes(game: Game): JsValue = {
      Json.toJson(game.gameStates)
    }

    def reads(json:JsValue): JsResult[Game] = {
      //need this to satisfy compiler
      JsSuccess(Game(-1, Seq(), Map(), Map(), new EndGame("", (x: GameState) => None)))
    }
  }

  implicit object GameIndexable extends Indexable[Game] {
    override def json(game: Game): String =
      game.gameStates.map(x => Json.toJson(x).toString()).mkString(",")
  }
}

インデックス作成を実行するための接続設定と方法は次のとおりです。

val settings = Settings.settingsBuilder()
                    .put("cluster.name", "elasticsearch_dan-dev").build()
val uri = ElasticsearchClientUri("elasticsearch://localhost:9300")
val esServer = ElasticClient.transport(settings, uri)

def sendGameToServer(game: Game) : Unit = {
  esServer.execute {
    index into "war" -> "games" source game
  }
}

アプリを実行すると、ゲーム オブジェクトのインデックスを作成しようとすると、Elasticsearch から次の例外が発生します。

[2016-02-22 13:34:28,247][DEBUG][action.index             ] [dan_01_dev] failed to execute [index {[war][games][AVMK56uUwAlQMxc6Khfa], source[_na_]}] on [[war][1]]
MapperParsingException[failed to parse]; nested: NotXContentException[Compressor detection can only be called on some xcontent bytes or compressed xcontent bytes];
    at org.elasticsearch.index.mapper.DocumentParser.innerParseDocument(DocumentParser.java:163)
    at org.elasticsearch.index.mapper.DocumentParser.parseDocument(DocumentParser.java:79)
    at org.elasticsearch.index.mapper.DocumentMapper.parse(DocumentMapper.java:304)
    at org.elasticsearch.index.shard.IndexShard.prepareCreate(IndexShard.java:500)
    at org.elasticsearch.index.shard.IndexShard.prepareCreateOnPrimary(IndexShard.java:481)
    at org.elasticsearch.action.index.TransportIndexAction.prepareIndexOperationOnPrimary(TransportIndexAction.java:214)
    at org.elasticsearch.action.index.TransportIndexAction.executeIndexRequestOnPrimary(TransportIndexAction.java:223)
    at org.elasticsearch.action.index.TransportIndexAction.shardOperationOnPrimary(TransportIndexAction.java:157)
    at org.elasticsearch.action.index.TransportIndexAction.shardOperationOnPrimary(TransportIndexAction.java:65)
    at org.elasticsearch.action.support.replication.TransportReplicationAction$PrimaryPhase.doRun(TransportReplicationAction.java:595)
    at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37)
    at org.elasticsearch.action.support.replication.TransportReplicationAction$PrimaryOperationTransportHandler.messageReceived(TransportReplicationAction.java:263)
    at org.elasticsearch.action.support.replication.TransportReplicationAction$PrimaryOperationTransportHandler.messageReceived(TransportReplicationAction.java:260)
    at org.elasticsearch.transport.TransportService$4.doRun(TransportService.java:350)
    at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: org.elasticsearch.common.compress.NotXContentException: Compressor detection can only be called on some xcontent bytes or compressed xcontent bytes
    at org.elasticsearch.common.compress.CompressorFactory.compressor(CompressorFactory.java:85)
    at org.elasticsearch.common.xcontent.XContentHelper.createParser(XContentHelper.java:50)
    at org.elasticsearch.index.mapper.DocumentParser.innerParseDocument(DocumentParser.java:99)
    ... 17 more

この例外に関する情報が見つかりません。オブジェクトが適切にフォーマットされていないためにインデックスが作成されていないことを意味することは理解していますが、それ以外のトラブルシューティング方法がわかりません。インデックスを作成するのではなく、Json を印刷すると、有効な Json があることを確認しました。Elasticsearch がインデックスを作成しようとしている Json を好まない理由について何か考えはありますか?

4

1 に答える 1

1

マップの結果をGameIndexable呼び出し.mkString(",")ているため、次のような「json」文字列になります。

{ ... }, { ... }, { ... }

これは有効な Json ではありません。複数のゲーム ステートのインデックスを作成する場合は、一括リクエストを作成する必要があり、それぞれに 1 つのゲーム ステートが含まれます。

Gameまたは、オブジェクトにインデックスを付けたい場合は、次のGameIndexableようにする必要があります。

implicit object GameIndexable extends Indexable[Game] {
  override def json(game: Game): String = GameFormat.writes(game).toString
}
于 2016-02-23T00:23:25.967 に答える