DELETEについても通知を受け、Elasticsearchでそれぞれのレコードを削除する必要がある場合は、Logstashjdbc入力が役に立たないことは事実です。 ここで提案
ただし、Logstash jdbc入力を引き続き使用する場合は、PostgreSQLでレコードをソフト削除するだけです。つまり、レコードをdeleted
としてマークするために新しいBOOLEAN列を作成します。 。同じフラグがElasticsearchに存在し、単純なterm
を使用して検索から除外できます。 deleted
に対するクエリ フィールド。
クリーンアップを実行する必要があるときはいつでも、deleted
のフラグが付いたすべてのレコードを削除できます。 PostgreSQLとElasticsearchの両方で。