PostgreSQL
 sql >> Base de données >  >> RDS >> PostgreSQL

Le client MQTT s'abonne aux modifications de la base de données PostgreSQL

Ok cette idée est intéressante j'utilise PostgreSQL 9.5 et dans la console si je tape CREATE LANGUAGE plpythonu; le langage python est disponible.Mais comment puis-je recevoir toute la base de données et les changements périodiques de la base de données dans mon courtier.

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;