SwampDragonの使い方 (その4) - Raspberry Pi & Python 開発ブログ ☆彡

前回まででデータベースの値を変更するとリアルタイムでWebページの値が更新されるようにすることができました。今回は、pythonからdjangoシステムにアクセスして、データベースに値を保存する方法を紹介します。

それではpythonコードを紹介します。

swampdragon-py-clientモジュールのダウンロード

下記サイトのモジュールを使用します。下記URLからsdclient.pyをRaspberry Piにダウンロードします。

https://github.com/jonashagstedt/swampdragon-py-client/tree/master/pyclient

websocket-clientのインストール

上記モジュールはwebsocket-clientを使用しますので、下記コマンドでインストールします。

sudo pip3 install websocket-client

pythonコードからdjangoシステムにアクセスする方法

それほど難しくありませんので、まずはコードにざっと目を通してください。

※url = 'ws://xxx.xxx.xxx.xxx:9999/data'のxxx.xxx.xxx.xxxにはRaspberryPiのIPアドレスを記載してください。

from sdclient import DragonClient

def on_channel_message(channel, message):
    print(channel)
    print(message)
    if channel == 'ch-pidata':
        output = '{} says: {}'.format(message.get('name'), message.get('message'))
        print(output)

def on_subscribed(context, message):
    print('-subscribed-')

def on_updated(context, message):
    print('-updated-')
    
url = 'ws://xxx.xxx.xxx.xxx:9999/data'
client = DragonClient(url, on_channel_message=on_channel_message)
client.connect()

client.call_router('subscribe', 'pidata_router', callback=on_subscribed, channel='ch-pidata')

client.call_router('update', 'pidata_router', callback=on_updated, id='1', pidata1='123' , pidata2='234')