私はDBとテレグラフの世界に流入するのは初めてです。できるだけ明確になることを願っています。
私はアーキテクチャを実装しようとしています:
マシン「A」は、特定のトピック/xxx を使用して MQTT ブローカーにデータを送信します。
Telegraf は topic/xxx のメッセージを検出し、収集したデータを InfluxDB バケットに送信します。
問題は：
キュー内のメッセージを削除できることをマシン A に伝えることができるように、流入 DB の書き込みプロセスが正しいことを確認するにはどうすればよいですか?
メッセージを生成したマシンに「メッセージは DB に保存されました。これで忘れることができます」というメッセージを送信したいだけです。特定のトピックに送信されるすべてのメッセージを保存する必要があります。
私が持っている唯一のアイデアは、テレグラフで出力プラグインからコードを再コンパイルし、書き込みプロセスの結果をチェックして、メッセージ ID と「書き戻し」ペイロードを使用して新しい MQTT メッセージをブローカーに送り返すことです。
しかし、わかりません。複雑すぎるようです。何かを見逃していたに違いありません。