MQTTクライアントはPostgreSQLDBの変更をサブスクライブします

このアイデアは興味深いものです。PostgreSQL9.5を使用しており、CREATELANGUAGEplpythonuと入力するとコンソールに表示されます。 Python言語が利用可能です。しかし、データベース全体とデータベースの定期的な変更をブローカーに受け取るにはどうすればよいですか。

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;