ゆっくりラズパイ活用講座

$ vi search.py import json, config from requests_oauthlib import OAuth1Session CK = config.CONSUMER_KEY CS = config.CONSUMER_SECRET AT = config.ACCESS_TOKEN ATS = config.ACCESS_TOKEN_SECRET SN = '@'+config.SCREEN_NAME twitter = OAuth1Session(CK,CS,AT,ATS) url = "https://api.twitter.com/1.1/search/tweets.json" params ={'q':SN,'count':10} res = twitter.get(url, params = params) since_id = "" if res.status_code == 200: timelines = json.loads(res.text) for line in timelines['statuses']: print(line['user']['name']) print(line['user']['screen_name']) print(line['created_at']) print(line['id_str']) print(line['text']) print(line['in_reply_to_status_id_str']) print('-------------------------------------------') if since_id == "": since_id = line['id_str'] else: print("Failed: %d" % res.status_code) print("since_id: %s" % (since_id))

#coding:UTF-8 import requests, config LT = config.LINE_TOKEN def main(): url = "https://notify-api.line.me/api/notify" headers = {"Authorization" : "Bearer "+ LT} message = 'これは、project_pi botから送信しています' payload = {"message" : message} r = requests.post(url ,headers = headers ,params=payload) if __name__ == '__main__': main()

import MySQLdb, json, requests, config
from requests_oauthlib import OAuth1Session

SN  = config.SCREEN_NAME

UR = config.MYSQL_USER
PW = config.MYSQL_PASSWORD
DB = config.MYSQL_DBNAME
TB = config.MYSQL_TBLNAME

CK  = config.CONSUMER_KEY
CS  = config.CONSUMER_SECRET
AT  = config.ACCESS_TOKEN
ATS = config.ACCESS_TOKEN_SECRET
LT  = config.LINE_TOKEN

connection = MySQLdb.connect(
    host='localhost', user=UR, passwd=PW, db=DB, charset='utf8')
cursor = connection.cursor(MySQLdb.cursors.DictCursor)

query = 'select since_id from '+TB+' where screen_name=\''+SN+'\''

since_id = ""
cursor.execute(query)
for row in cursor:
    since_id = row['since_id']

twitter = OAuth1Session(CK,CS,AT,ATS)
url = "https://api.twitter.com/1.1/search/tweets.json"
params ={'q':'@'+SN+' ','since_id':since_id,'count':10}
res = twitter.get(url, params = params)

since_id = ""

if res.status_code == 200:
    timelines = json.loads(res.text)

    url = "https://notify-api.line.me/api/notify"
    headers = {"Authorization" : "Bearer "+ LT}

    for line in timelines['statuses']:
        name        = line['user']['name']
        screen_name = line['user']['screen_name']
        created_at  = line['created_at']
        id          = line['id_str']
        text        = line['text']
        reply_id    = line['in_reply_to_status_id_str']
        if since_id == "":
            since_id = line['id_str']

        tweet = created_at[4:19]+' '+name+'@'+screen_name+' > '+text
        payload = {"message" :  tweet}
        r = requests.post(url ,headers = headers ,params=payload)

else:
    print("Failed: %d" % res.status_code)

if since_id != "":
    cursor.execute("update %s set since_id=%s where screen_name='%s'" % (TB, since_id, SN))
    connection.commit()

connection.close()