Khách hàng MQTT đăng ký các Thay đổi của PostgreSQL DB

Ok, ý tưởng này thật thú vị, tôi đang sử dụng PostgreSQL 9.5 và trong bảng điều khiển nếu tôi gõ CREATE LANGUAGE plpythonu; ngôn ngữ python có sẵn. Nhưng làm cách nào tôi có thể nhận toàn bộ cơ sở dữ liệu và các thay đổi định kỳ của cơ sở dữ liệu vào Nhà môi giới của tôi.

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;