我是涌入数据库和电报世界的新手，我希望我会尽可能清楚。
我正在尝试实现一个架构，其中：
机器“A”将数据发送到具有特定主题/xxx 的 MQTT 代理。
Telegraf 检测到 topic/xxx 的消息并将收集到的数据发送到 InfluxDB 存储桶。
问题是：
如何确定流入数据库中的写入过程是正确的，以便我可以告诉机器 A 它可以删除其队列中的消息？
我只想向生成消息的机器发送一条“好的，消息已存储在数据库中，现在您可以忘记它了”。我必须存储发送到某个主题的每条消息。
我唯一的想法是从电报中的输出插件重新编译代码，并检查编写过程的结果，然后使用消息 ID 和“写回”有效负载将新的 MQTT 消息发送回代理。
但我不知道，这似乎太复杂了，我一定是错过了什么。