elasticsearch - elasticsearch jdbc river プラグインは、mysql の既存の行への変更を追跡しますか?

Question

シンプル戦略モードの jdbc リバー プラグインは、新しい行が追加されるとインデックスを更新しますが、フィールド値に変更がある場合、既存の行を更新しますか? データベース内のタイムスタンプ フィールドとのマッピングがないことに気付いたので、そうではないと推測します。

Answer 1

$river.state.last_active_begin以下の例のようにを使用して、クエリ内でタイムスタンプを使用できます。これにより、最後のリバー ラン以降に追加された製品の行がフェッチされます。

{
  "type": "jdbc",
  "jdbc": {
    "url": "jdbc:mysql://localhost:3306/test",
    "user": "",
    "password": "",
    "sql": [
      {
        "statement": "select * from \"products\" where \"mytimestamp\" > ?",
        "parameter": [
          "$river.state.last_active_begin"
        ]
      }
    ],
    "index": "my_jdbc_river_index",
    "type": "my_jdbc_river_type"
  }
}