HOME | Raspberry Pi | ビジネス書籍紹介 | 2021-09-19 (Sun) Today's Access : 107 Total : 354101. Since 10 Sep. 2019

Twitter-LINE連携によるビジネス活用
2020.04.24

YouTubeでポイントを説明しています。画像をクリックすると再生できます。

今回は、Twitter に届いたツイートを、LINE に流し込む仕組みを構築します。
具体的には、あるプロジェクトで、その代表アカウントにツイートしたとします。
ラズパイ上のプログラムはツイートへの返信を監視して、返信があったときに、そのプロジェクトメンバーで構成されているライン・グループに自動的に投稿します。
プロジェクトのメンバーが、ライン上で返信に関して検討・意見交換をできるようにします。まあ、テレワーク的に仕事ができちゃうってところでしょうか。


■Twitterアプリ登録

Twitterが提供するAPIを使って、アプリケーションを作成するためには、Twitterへのアプリ登録が必要になります。
登録に関しては、【参考文献】のURLを参考にしてください。

アプリを登録して、各種Keyを発行します。
・Consumer Key(API Key)
・Consumer Secret(API Secret)
・Access Token
・Access Token Secret

Python用の設定ファイルを作成します
$ vi config.py
CONSUMER_KEY = "**********************"
CONSUMER_SECRET = "**********************"
ACCESS_TOKEN = "**********************"
ACCESS_TOKEN_SECRET = "**********************"
SCREEN_NAME = "project_pi"

ここでは、Twitter ユーザ名(スクリーンネーム)を "@project_pi" としています。

■python リクエスト・認証用ライブラリのインストール

pip3 をインストールしていない場合
$ sudo apt install python3-pip

$ sudo pip3 install requests requests-oauthlib

$ 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))
$ python3 search.py

検索結果
-------------------------------------------
とある技術者1
engineer_1
Wed Apr 22 03:32:07 +0000 2020
1252802335086006272
@project_pi こんにちは、便利そうですね
1243502763658473472
-------------------------------------------
とある技術者2
engineer_2
Thu Apr 16 09:28:42 +0000 2020
1250738477866042369
RT @project_pi: ラズパイ活用講座 M5Stackキーボードを利用する
None
-------------------------------------------
since_id: 1252802335086006272

返信ツイートの場合、in_reply_to_status_id_str に返信元ツイート番号がはいります。
リツイートの場合は、None なので、この項目をみることでツイートの種類がわかります。

検索結果には、新しいものから古いものの順に格納されています。
ここでのポイントは、検索結果の一番最初のツイート番号を保存(since_id)して、 次回検索時の開始点として利用します。
params ={'q':SN,'since_id':'1252802335086006272','count':10}

1回の検索で取得できる最大ツイート数は200件ですが、 Twitter炎上にも備えて、取得するツイート数指定の count パラメターは、10程度に抑えておきましょう。
Twitter API では過去1週間以内のものが取得できます。

■Python3 で MySQL を使うための準備
ここでは、MySQLデータベース管理システムはすでにインストール済みとしています。
インストールの詳細は Raspberry Pi 3B+ 自宅WEBサーバ構築 第6回MySQL設定をご覧ください。
MySQLのデータベースに下記のようなテーブルを追加します。
create table sample_tbl(
	screen_name  varchar(32) default null,
	since_id     varchar(32) default null
) ENGINE=MyISAM default charset=utf8 auto_increment=1;
Twitter代表アカウントのレコードを1件追加します。
$ sudo mysql --user=root -p mysql
mysql> use sample_db;
mysql> insert into sample_tbl(screen_name) values('project_pi');

$ vi config.py
....
MYSQL_USER = "**********"
MYSQL_PASSWORD = "**********"
MYSQL_DBNAME = "sample_db"
MYSQL_TBLNAME = "sample_tbl"

Python用の MySQLクライアントをインストールします。
$ sudo apt-get install libmysqlclient-dev
$ sudo pip3 install mysqlclient

$ vi update.py
import MySQLdb, config

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

since_id = "1252802335086006272"

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

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

■LINENotifyの利用


通知の際に表示されるトークン名と、通知を送信するトークルームを選択して、トークンを発行します。
LINE Notify への登録方法は文末の【参考文献】を参照してください。

$ vi config.py
....
LINE_TOKEN = "********************"

$ vi lineNotify.py
#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()


■プログラムの統合
単体テストを行ってきたプログラムを1つに纏めます。
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()


■crontab設定

$ vi project_pi.sh
#!/bin/bash
#
/usr/bin/python3 /home/ubuntu/scripts/project_pi.py > bot.log 2>&1

$ chmod u+x project_pi.sh

朝9時から午後5時まで15分間隔で処理を実行する。
$ sudo vi /etc/crontab */15 9-17 * * * root /home/ubuntu/scripts/project_pi.sh

$ sudo service cron restart

■補足
実際には、代表アカウントからの発信ツイートもプログラムから行います。
発信・返信ツイートすべてをデータベースに格納して、返信ツイート中の返信元ツイート番号から、該当する発信ツイートを検索・表示できるようにします。

■参考文献
第23回「Raspberry PiからTwitterへ情報発信!(1) Twitter API編」
PythonでTwitter API を利用していろいろ遊んでみる
Standard search API
Python3でMySQLを使う
pythonでLINENotify使ってみる
 Raspberry Pi(ラズベリー パイ)は、ARMプロセッサを搭載したシングルボードコンピュータ。イギリスのラズベリーパイ財団によって開発されている。
2020.04.24 Twitter-LINE連携によるビジネス活用
2021.02.27 TweLite Neural Network 第1回環境設定
2021.07.24 形態素解析 TreeTagger


ニーア オートマタ PLAY ARTS改 <ヨルハ 二号 B型 DX版> PVC製 塗装済み可動フィギュア
「NieR:Automata」より、ヨルハ二号B型こと2BがPLAY ARTS改に新たに登場! 高級感の感じられるコスチュームや髪の質感、洗練されたボディバランス、細かなデティールに至るまでこだわり抜かれた逸品。 DX版には通常版のラインナップに加え2Bの随行支援ユニット ポッド042などをはじめ“純白の美しい太刀"白の約定やエフェクトパーツ、自爆モードを再現できる換装用ボディパーツ、シーンに合わせて変えられる顔パーツ2種も付属する豪華な仕様に。 作中のあらゆるシーンを再現することが可能なファン必見の一品となっている。

DIPスイッチで動作電圧を3.3Vと5Vに切り替えられるUNO互換ボード
KEYESTUDIO Plus Board for Arduino UNO R3 with Type-C USB Cable, 3.3V 5V 1.5A Output Current, More Powerful Controller Board USB-シリアルチップ:CP2102 / 動作電圧:5Vまたは3.3V(DIPスイッチ制御)/ 外部電源:DC 6-15V(9V推奨)/ デジタルI / Oピン:14(D0〜D13)/ PWMチャネル:6(D3 D5 D6 D9 D10 D11)/ アナログ入力チャネル(ADC):8(A0-A7)/ DC出力機能の各I / Oポート:20 mA / 3.3Vポートの出力能力:50 mA / フラッシュメモリ:32 KB(うち0.5 KBはブートローダーによって使用されます)/ SRAM:2 KB(ATMEGA328P-AU)/ EEPROM:1 KB(ATMEGA328P-AU)/ クロック速度:16MHz / オンボードLEDピン:D13

エレクトロクッキー Leonardo R3 ATmega32u4 ボード DIY Arduino工作用 - ピンクエディション


Newtonライト2.0 ベイズ統計
ベイズ統計は,結果から原因を推定する統計学です。AIや医療などの幅広い分野で応用されています。その基礎となるのは18世紀に考えだされた「ベイズの定理」です。 この本では,ベイズ統計学のきほんをやさしく紹介していきます。

Interface 2021年10月号
☆特集:~ 格好良さアップ! 機能&信頼性アップ ! ~「 3Dプリンタ & メカ設計入門 」
☆特集2:Pico達人への道…「 C/C++でMicroPython拡張 」


トランジスタ技術 2021年9月号
☆特集:~ 直流・交流・非接触・センサ微小電流の測定ノウハウ ~「電流を正しく測る技術」

トランジスタ技術スペシャル 2021年7月号 宇宙ロケット開発入門
これから開発・活用が進むと期待されている宇宙空間への交通・物流インフラとして、小型・低価格ロケットが注目を集めています。本書では、基本構造から制御メカニズムまで、小型宇宙ロケット開発の基礎知識を実例を交えて解説します。

日経Linux 2021年9月号
【特集1】おうち時間をLinuxデスクトップで楽しむ! Linux環境を作るワザ
【特集2】徹底図解で丸わかり! 「WSL2」入門   Windows 11の新機能を速報!
【特集3】IT自動化ツール AnsibleでWeb導入を自動化
【特集4】ラズパイで楽しむLinuxライフ 「今、会議中」と家族に伝えるプレートをPythonで作ろう


ラズパイマガジン2021年秋号
特集1 サクッと動くパーツ&ライブラリ総覧
特集2 ArduinoライブラリでラズパイPicoを動かす
特集3 古いラズパイをフル活用! Node-REDで 楽しい電子工作
特集4 空気の汚れをラズパイで検知しよう
特集5 ラズパイで楽しむLinuxライフ
特集6 NVIDIAのAIボードが6000円台に!
特集7 M5StickCで始める電子工作 iPhoneからサーボモーターを制御しよう


トランジスタ技術スペシャル 2021年 4月号 No.154「達人への道 電子回路のツボ」
初学者が実用的な電子回路を設計できるようになるためのポイントをまとめました。学校の教科書だけではつかめない基本電子回路やOPアンプ/トランジスタの使い方の実際を、いろいろな視点から解説しています。


Raspberry Pi 3 Model B V1.2 (日本製) 国内正規代理店品
【仕様概要】CPU:ARM 1.2GHz 4コア、GPU:2コア 3D・動画支援、RAM:1GB、ネットワーク:LAN/Wi-Fi/Bluetooth、インターフェース:USB/HDMI/オーディオ/GPIO(UART/I2C/I2S/SPI...)。

ELEGOO Arduino用 Nanoボード V3.0 CH340/ATmega328P、Nano V3.0互換 (3)


ESPr Developer 32
スイッチサイエンス(Switch Science)

協和ハーモネット UL1007 AWG24 耐熱ビニル絶縁電線 リール巻 100m 黒


白光(HAKKO) ダイヤル式温度制御はんだ吸取器 ハンディタイプ FR301-81


サンハヤト TTW-203 テストワイヤ
ブレッドボードとスルーホール間の接続に便利なワイヤですブレッドボード用のオスピンと基板のスルーホール用のバネ性のある端子を組み合わせたテストワイヤです

無水エタノールP 500mlx2個パック(掃除)


ケイバ(KEIBA) マイクロニッパー MN-A04


熱収縮チューブφ1.5
印字無しで綺麗☆ シュリンクチューブ 絶縁チューブ 防水 高難燃性 収縮チューブ (2m, ブラック(黒))


サンハヤト SAD-101 ニューブレッドボード


白光(HAKKO) HEXSOL 巻はんだ 精密プリント基板用 150g FS402-02


【Amazon.co.jp限定】エーモン 電工ペンチ 全長約255mm (1452)


[Amazon限定ブランド]【指定第2類医薬品】PHARMA CHOICE 解熱鎮痛薬 解熱鎮痛錠IP 100錠


Copyright © 2011-2022 Sarako Tsukiyono All rights reserved®.