MQTT क्लाइंट PostgreSQL DB परिवर्तन की सदस्यता लेता है

ठीक है, यह विचार दिलचस्प है, मैं PostgreSQL 9.5 का उपयोग कर रहा हूं और कंसोल में यदि मैं CREATE LANGUAGE plpythonu टाइप करता हूं; पायथन भाषा उपलब्ध है। लेकिन मैं अपने ब्रोकर में पूरे डेटाबेस और डेटाबेस के समय-समय पर होने वाले परिवर्तनों को कैसे प्राप्त कर सकता हूं।

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;