【tweepy】botをメンションした人へリアルタイムでリプライする機能を実装したい

Question

よくある○○%で言葉がそろう系のbotを作成していて、サブ要素的な感じでbotをメンションした人へリプライをする機能を実装したいです。現在はscheduleモジュールを使って10秒おきにプログラムを実行しているのですが、うまくメンションしたアカウントを取得できていないのか、メンションをしても一向にリプライが送られてきません。どうすればよいか、有識者の方ご教授願います。

import tweepy
import random
import time
import datetime
import schedule
def job():
    print(datetime.datetime.now())

schedule.every(10).seconds.do(job)

Twitter_ID = "---------------------------"
SCREEN_NAME = '---------------------------------'
CONSUMER_KEY = "---------------"
CONSUMER_SECRET = "----------------------------------------------"
ACCESS_TOKEN = "-----------------------------------------------------"
ACCESS_TOKEN_SECRET = "------------------------------------------------"

auth = tweepy.OAuthHandler(CONSUMER_KEY, CONSUMER_SECRET)
auth.set_access_token(ACCESS_TOKEN, ACCESS_TOKEN_SECRET)
item_list = [...割愛...]

api2 = tweepy.API(auth)
status = api2.mentions_timeline()
for mention in status:
    reply_text = "@"+str(mention.user.screen_name)+" "+ random.choice(item_list)
    api2.update_status(status = reply_text, in_reply_to_status_id = mention.id)

while True:
    schedule.run_pending()
    time.sleep(1)

プログラムはこんな感じです。
最初の実行ではしっかりとプライが届いていますが、一度実行した後にメンションした場合にはリプライが届いていないといった感じです。

試したこと

while文での無限ループを試みたのですがそれもうまくいきませんでした。先述の通り、scheduleモジュールで１０秒ごとに実行してもうまくいっていません。

実現したいこと

botをメンションしたツイートへリアルタイムで自動でリプライをできるようにしたい。

Answer 1

ご質問のコードでスケジュールされているのはjob関数であり、その中身は時刻を標準出力に出力するだけのようです。

def job():
    print(datetime.datetime.now())

schedule.every(10).seconds.do(job)

正直な話、私はTwitterのAPIやTweepyには詳しくありませんが、以下のようにタイムラインの取得とリプライをjob関数内で行うべきではないでしょうか。

api2 = tweepy.API(auth)

def job():
    status = api2.mentions_timeline()
    for mention in status:
        reply_text = "@"+str(mention.user.screen_name)+" "+ random.choice(item_list)
        api2.update_status(status = reply_text, in_reply_to_status_id = mention.id)

schedule.every(10).seconds.do(job)

また、軽く調べてみると、Botのような継続的にツイートを監視する用途にはREST APIよりもStreaming APIの方が向いているかもしれません。
Tweepyにも継続監視ためのStreamListenerという仕組みが用意されているようです。

Tweepyでストリーミング - Python日本語ドキュメント

具体的にどんな感じで使うのかは以下の記事が参考になるかもしれません。
情報が古いかもしれませんので、上記のドキュメントと併せて読んでみてください。

Tweepyで雑にTwitter botを作ってみた - Qiita

以上、ご参考になれば幸いです。

Comments

[kabos0809]

一度StreamListenerを試してはいるのですが、その時はAttribute errorになってしまいました。調べてみたところ、StreamListenerはStreamで統一されたようで、StreamListenerとしていたところをStreamに書き替えたらうまく動くようになりました。
回答ありがとうございました。