MQTTクライアントがPostgreSQL DBの変更を購読する

Question

定期的に更新され、最新の変更をmosquittoブローカーに公開したいPostgreSQL DBがあります。 このアプローチを行う最もエレガントな方法は何ですか？

Answer 1

Postgressは、作成/更新トリガーから呼び出すことができるPython stored proceduresをサポートしているようです。

PAHOのPythonクライアントと組み合わせるこれは、あなたが、私は言語plpythonuというのCREATE入力すると

Answer 2

は、[OK]を、このアイデアは、私は、PostgreSQL 9.5を使用して、コンソールにしています面白いです何をしたいだろう。 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; 

Answer 3

Postgressには独自のパブリッシュ/サブスクライブシステムがあります。listen/notify。パブリッシュする情報のために、適切な（聴取）通知チャネルをポストバックで設定します。通知ペイロードは、mqttメッセージ文字列としてフォーマットできます。それらをリッスンしてmqtt-brokerにパブリッシュするクライアントを作成します。