cloudbits_api_tataku.py

import requests
import json
import tweepy

#TwitterAPI Settings
CONSUMER_KEY = ""
CONSUMER_SECRET = ""
ACCESS_TOKEN = ""
ACCESS_TOKEN_SECRET = ""
#littleBits(cloudbBits) Settings
DEVICE_ID = ""
CLOUDBITS_ACCESS_TOKEN = ""

url = "https://api-http.littlebitscloud.cc/v2/devices/" + DEVICE_ID + "/output"
headers = {"Authorization": "Bearer " + CLOUDBITS_ACCESS_TOKEN, "Content-type": "application/json"}
payload = { "percent": 100, "duration_ms": 3000 }

class MyStreamListener(tweepy.StreamListener):

    def on_status(self, status):
        # print(status.text)
        pass
    def on_event(self, event):
        if event.event == "favorite":
            print("favorite")
            r = requests.post(url, data=json.dumps(payload) ,headers=headers)
            print(r)

auth = tweepy.OAuthHandler(CONSUMER_KEY, CONSUMER_SECRET)
auth.set_access_token(ACCESS_TOKEN, ACCESS_TOKEN_SECRET)

api = tweepy.API(auth)

myStreamListener = MyStreamListener()
myStream = tweepy.Stream(auth = api.auth, listener=myStreamListener)
myStream.userstream()