java - MQTT 客户端订阅 PostgreSQL DB Changes

Question

我有一个定期更新的 PostgreSQL 数据库，并且想将最新的更改发布到 mosquitto 代理。执行此方法最优雅的方法是什么？

Answer 1

好的，这个想法很有趣，我正在使用 PostgreSQL 9.5，如果我在控制台中键入 CREATE LANGUAGE plpythonu； python语言可用。但是我如何才能将整个数据库和数据库的定期更改接收到我的 Broker 中。

CREATE FUNCTION publishChanges ()
  RETURNS integer
AS $$
  import paho.mqtt.client as mqtt
  import paho.mqtt.publish as publish
  #client = mqtt.Client()
  #client.connect("localhost", 1883, 60)

  publish.single("test/data", SELECT * from table ,hostname="127.0.0.1")

  #client.loop_forever()
$$ LANGUAGE plpythonu;