Добре, тази идея е интересна, използвам PostgreSQL 9.5 и в конзолата, ако напиша CREATE LANGUAGE plpythonu; езикът 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;