การเขียนโปรแกรมภาษา Python เพื่อส่งข้อมูลไปยัง NETPIE - mrolarik/simple-iot GitHub Wiki

$ sudo pip install microgear

Collecting microgear
  Downloading microgear-1.1.3.zip
Collecting paho-mqtt (from microgear)
  Downloading paho-mqtt-1.1.tar.gz (41kB)
    100% |████████████████████████████████| 45kB 274kB/s 
Collecting oauth2 (from microgear)
  Downloading oauth2-1.9.0.post1-py2.py3-none-any.whl
Collecting requests (from microgear)
  Downloading requests-2.7.0-py2.py3-none-any.whl (470kB)
    100% |████████████████████████████████| 471kB 231kB/s 
Collecting httplib2 (from oauth2->microgear)
  Downloading httplib2-0.9.2.tar.gz (205kB)
    100% |████████████████████████████████| 208kB 332kB/s 
Installing collected packages: paho-mqtt, httplib2, oauth2, requests, microgear
  Running setup.py install for paho-mqtt
  Running setup.py install for httplib2
  Running setup.py install for microgear
Successfully installed httplib2-0.9.2 microgear-1.1.3 oauth2-1.9.0.post1 paho-mqtt-1.1 requests-2.7.0

import microgear.client as microgear
import time
import logging

appid = <appid>
gearkey = <gearkey>
gearsecret =  <gearsecret>

microgear.create(gearkey,gearsecret,appid,{'debugmode': True})

def connection():
    logging.info("Now I am connected with netpie")

def subscription(topic,message):
    logging.info(topic+" "+message)

def disconnect():
    logging.debug("disconnect is work")

microgear.setalias("doraemon")
microgear.on_connect = connection
microgear.on_message = subscription
microgear.on_disconnect = disconnect
microgear.subscribe("/mails")
microgear.connect(False)

while True:
	if(microgear.connected):
		microgear.chat("doraemon","Hello world."+str(int(time.time())))
time.sleep(3)

appid = <appid>
gearkey = <gearkey>
gearsecret =  <gearsecret>

#----------netpie_message.py----------------
import microgear.client as netpie
import base64, zlib, time
import random
import datetime

key = '<your/key>'
secret = '<your/secret/number>'
app = '<your/application/id>'

netpie.create(key,secret,app,{'debugmode': True})

def connection():
	print "Now I am connected with netpie"

def subscription(topic,message):
	print topic+" "+message

netpie.setname("smartFarm")
netpie.on_connect = connection
netpie.on_message = subscription
netpie.subscribe("/mails")

netpie.connect()

while True:
	T1 = random.randint(0,100)		
	H1 = random.randint(0,100)
	smartFarm_message = str(T1) + "," + str(H1)
	print(smartFarm_message)
				
	netpie.chat("smartFarm",smartFarm_message)
	time.sleep(5)

smartFarm_message = str(T1) + "," + str(H1)

$ python netpie_message.py

19/08/2018 01:54:07 AM WARNING  Deprecated soon: Please consider using setalias()
19/08/2018 01:54:07 AM INFO     Check stored token.
19/08/2018 01:54:08 AM INFO     Connected with result code 0
Now I am connected with netpie
19/08/2018 01:54:08 AM INFO     Auto subscribe /SFM/gearname/smartFarm
19/08/2018 01:54:08 AM INFO     Auto subscribe /SFM/mails
19/08/2018 01:54:08 AM INFO     Auto subscribe /&id/uOyBbeWxp22nyGgE/#
/SFM/gearname/smartFarm 64,53
/SFM/gearname/smartFarm 35,47
/SFM/gearname/smartFarm 30,61
/SFM/gearname/smartFarm 32,84