Tweepyを使ってある特定のアカウントのツイートをDiscordに送信したい

Question

前提

Python、Discord Botともに初心者です。

tweepy(3.10.0)とDiscord.py(1.7.3)で、tweepyである特定のアカウントのツイートをリアルタイムで取得してDiscord.pyを用いてDiscordサーバーに送信するというものを作ろうとしています。
リアルタイムでのツイートの取得まではうまく行ったのですが、Discordに送信するところが動きません…

実現したいこと

Tweepyでツイートが取得できるたびにDiscordで送る

該当のソースコード

import tweepy
import discord
from discord.ext import tasks

TOKEN = '*******************' # TOKENを貼り付け
CHANNELID = ******************* # チャンネルIDを貼り付け

client = discord.Client()

consumer_key = "*******************"
consumer_secret = "*******************"
access_key = "*******************"
access_secret = "*******************"

auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_key, access_secret)
api = tweepy.API(auth)

@client.event
async def on_ready():
    print('起動しました')

#override tweepy.StreamListener to add logic to on_status
class MyStreamListener(tweepy.StreamListener):


    def on_status(self, status):
        print(status.text)
        tt = status.text
        async def sendtext():
            await channel_sent.send(tt)
            channel_sent = client.get_channel(CHANNELID)
            

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

myStream.filter(follow=["*******************"])

client.run(TOKEN)

試したこと

下記のようにして10秒ごとにDiscordにTweepyで取得したものを送信するようにして、どこかで変化するからOK!みたいにしてみたのですが、10秒間隔でずっと同じものを送信するだけのスパムになってしまいました。

import tweepy
import discord
from discord.ext import tasks

TOKEN = '*******************' # TOKENを貼り付け
CHANNELID = ******************* # チャンネルIDを貼り付け

client = discord.Client()

consumer_key = "*******************"
consumer_secret = "*******************"
access_key = "*******************"
access_secret = "*******************"

auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_key, access_secret)
api = tweepy.API(auth)

@client.event
async def on_ready():
    print('起動しました')

#override tweepy.StreamListener to add logic to on_status
class MyStreamListener(tweepy.StreamListener):

    def on_status(self, status):
        print(status.text)
        tt = status.text
        @tasks.loop(seconds=10)
        async def send_message_every_10sec():
            await channel_sent.send(tt)
        @client.event
        async def on_ready():
            global channel_sent 
            channel_sent = client.get_channel(CHANNELID)
            send_message_every_10sec.start() #定期実行するメソッドの後ろに.start()をつける
        client.run(TOKEN)

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

myStream.filter(follow=["*********************"])

よろしくお願いします。

Answer 1

channel_sentが定義される前に送信しようとしていることが原因だと思われますので、以下のコードで試してみてください。

async def sendtext():
            channel_sent = client.get_channel(CHANNELID)
            await channel_sent.send(tt)

Comments

[Sopi_Eizo]

ありがとうございます。情報不足でした。すみません…
TwitterでRTしたものがプリントされるのはできているのですが、まずDiscordBotが起動しません。

[start]

返信遅れて申し訳ございません。
classの中にdiscord.pyのbot部分の実装コードが書かれていると思うので、discord.py関連の処理をclass外にすれば治るかと思われます。

[Sopi_Eizo]

返信ありがとうございます。
下記の①の様に変更してみたのですが、するとDiscord.pyは動かずに、tweepyだけ動くようになりました。
client.run(TOKEN)の位置が悪いのかなと思い、それの位置を変えてみました。（②）
すると今度は、Discord.pyは動いたのですがtweepyは動かなくなりました。

①~~~上記省略~~~
class MyStreamListener(tweepy.StreamListener):
def on_status(self, status):
print(status.text)
tt = status.text

async def sendtext():
channel_sent = client.get_channel(CHANNELID)
await channel_sent.send(MyStreamListener.on_status.tt)

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

myStream.filter(follow=["***************"])

client.run(TOKEN)

--------------------------------------------

②~~~上記省略~~~
class MyStreamListener(tweepy.StreamListener):
def on_status(self, status):
print(status.text)
tt = status.text

async def sendtext():
channel_sent = client.get_channel(CHANNELID)
await channel_sent.send(MyStreamListener.on_status.tt)

client.run(TOKEN)

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

myStream.filter(follow=["***************"])

[start]

夜分遅くに失礼します。
myStreamListener = MyStreamListener()
myStream = tweepy.Stream(auth = api.auth, listener=myStreamListener)

myStream.filter(follow=["***************"])
をon_readyに入れてみてください。