如何从StreamListener处理程序(twitter)向电报发送消息？tweepy & telethon
从StreamListener处理程序(twitter)向电报发送消息的方法是使用tweepy和telethon这两个Python库。
首先，确保已经安装了tweepy和telethon库。可以使用以下命令进行安装：
pip install tweepy telethon接下来，需要在Twitter和Telegram上创建相应的开发者账号，并获取API密钥和访问令牌。具体步骤如下：
- 在Twitter上创建开发者账号，并创建一个新的应用程序。获取API密钥、API密钥密钥、访问令牌和访问令牌密钥。
- 在Telegram上创建一个新的机器人，并获取机器人的API令牌。
获取了所需的API密钥和令牌后，可以开始编写代码。以下是一个示例代码，演示如何从StreamListener处理程序向电报发送消息：
import tweepy
from telethon import TelegramClient
# Twitter API密钥和访问令牌
consumer_key = 'YOUR_TWITTER_CONSUMER_KEY'
consumer_secret = 'YOUR_TWITTER_CONSUMER_SECRET'
access_token = 'YOUR_TWITTER_ACCESS_TOKEN'
access_token_secret = 'YOUR_TWITTER_ACCESS_TOKEN_SECRET'
# Telegram API令牌和机器人ID
api_id = 'YOUR_TELEGRAM_API_ID'
api_hash = 'YOUR_TELEGRAM_API_HASH'
bot_token = 'YOUR_TELEGRAM_BOT_TOKEN'
bot_chat_id = 'YOUR_TELEGRAM_BOT_CHAT_ID'
# 创建Twitter认证
auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_token, access_token_secret)
# 创建Twitter API客户端
api = tweepy.API(auth)
# 创建Telegram客户端
client = TelegramClient('session_name', api_id, api_hash)
client.start(bot_token=bot_token)
# 创建自定义的StreamListener处理程序
class MyStreamListener(tweepy.StreamListener):
def on_status(self, status):
# 获取推文内容
tweet_text = status.text
# 发送消息到Telegram
client.send_message(bot_chat_id, tweet_text)
# 创建StreamListener实例
myStreamListener = MyStreamListener()
# 创建Stream对象并过滤推文
stream = tweepy.Stream(auth=api.auth, listener=myStreamListener)
stream.filter(track=['keyword1', 'keyword2']) # 根据关键字过滤推文
# 运行监听器
client.run_until_disconnected()在上述代码中，需要将YOUR_TWITTER_CONSUMER_KEY、YOUR_TWITTER_CONSUMER_SECRET、YOUR_TWITTER_ACCESS_TOKEN、YOUR_TWITTER_ACCESS_TOKEN_SECRET替换为你的Twitter API密钥和访问令牌。同样，将YOUR_TELEGRAM_API_ID、YOUR_TELEGRAM_API_HASH、YOUR_TELEGRAM_BOT_TOKEN、YOUR_TELEGRAM_BOT_CHAT_ID替换为你的Telegram API令牌和机器人ID。
代码中的MyStreamListener类是自定义的StreamListener处理程序，当接收到新的推文时，会将推文内容发送到Telegram。可以根据需要修改on_status方法来处理推文内容。
最后，通过stream.filter()方法可以根据关键字过滤推文。将关键字替换为你感兴趣的内容。
这是一个基本的示例，你可以根据自己的需求进行修改和扩展。关于tweepy和telethon的更多详细信息和用法，请参考官方文档：
- tweepy文档：https://docs.tweepy.org/
- telethon文档：https://docs.telethon.dev/
相关·内容
1回答
Tweepy StreamListener:指定账号发推文时发推文
python、python-2.7、twitter、bots、tweepy
我有一个Twitter机器人，它是跟随一个特定的帐户。当那个账号发推文的时候，我希望我的机器人也发推文。 到目前为止，我有以下代码： import tweepy
import time
import sys
import inspect
consumer_key = 'xxxxxxx'
consumer_secret = 'xxxxxxxx'
access_token = 'xxxxxxx'
access_token_secret = 'xxxxxxxx'
auth = tweepy.OAuthHandler(consume
浏览 13提问于2019-12-30得票数 2
1回答
API Twitter的权限
python、twitter、tweepy
我正在制作一个推特机器人来喜欢推特，一开始脚本是对的。问题在于twitter权限。它写着“只读”，没有选择去改变它，就像过去一样。有人也有同样的问题吗？总是在控制台上返回：“只读应用程序不能发布”，以下是脚本：
import tweepy
bearer_token = 'xxxxxxxxxx'
consumer_key = 'xxxxxxxxxxx'
consumer_secret = 'xxxxxxxxxxxx'
access_token = 'xxxxxxxxxxxxx'
access_token_secret = '
浏览 2提问于2022-04-29得票数 1
1回答
在twitter上跟踪指定用户名上的单词/文本
python、api、data-mining
我是开发API的初学者&使用Python，目前正在尝试使用Twitter API。我的代码在Twitter上运行搜索，功能就像Twitter页面顶部的搜索栏一样，在那里我可以在代码中替换我想要查找的任何字符串。但我只想为特定的用户名/帐户执行此操作。我是先对该用户名发起呼叫，还是单独编写代码？
import tweepy
import sys
class MyStreamListener(tweepy.StreamListener):
def on_status(self,status):
print(status.text)
def on_error
浏览 0提问于2020-12-02得票数 0
1回答
输入错误'class‘对象不可调用
python、tweepy
我有一个类MyStreamListener，我试图从另一个文件中调用它，但是我得到了type error 'MyStreamListener' not callable。根据我在引用用户创建类时所读到的内容，这可能是因为我试图访问python中的保留关键字，但我已经尝试更改了类的名称。我还做错什么了吗？
functionality.py
from authenticate import CONSUMER_KEY, CONSUMER_SECRET, ACCESS_TOKEN, ACCESS_TOKEN_SECRET
from twitter_stream import MyStr
浏览 3提问于2015-12-21得票数 6
回答已采纳
1回答
如何流式传输特定用户的tweet并将其作为变量返回
python、twitter、streaming、tweepy
我试图流式传输特定用户的推文，然后将它们作为一个变量返回给基于事件的触发器。我正在使用以下代码，但它似乎没有为我返回任何tweet。我只对他们的推文感兴趣，而不是转发，并想跳过不是由指定用户发布的推文。 你知道我哪里错了吗： import tweepy
#API login for Twitter
consumer_key= CONSUMER_KEY
consumer_secret= CONSUMER_SECRET
access_key= ACCESS_TOKEN
access_secret= ACCESS_TOKEN_SECRET
class StreamListener(tweepy
浏览 20提问于2020-12-04得票数 1
1回答
当尝试从Tweepy的特定帐户流live时返回401错误代码
python、twitter、tweepy、reddit、praw
有人知道是什么导致了这个错误吗？我所有的钥匙和记号都应该是正确的。我确保再检查一遍。我想，我很巧妙地遵循了如何设置这条小溪的步骤。
import time
import tweepy
import praw
#Variables that contains the credentials to access Twitter API and REDDIT
USERNAME = ""
PASSWORD = "!"
CLIENT_ID = ''
CLIENT_SECRET = ''
consumer_key = ''
浏览 5提问于2022-03-04得票数 0
1回答
如何从StreamListener处理程序(twitter)向电报发送消息？tweepy & telethon
python、tweepy、telethon
在启动脚本后，我设法只发送了一条消息，在此之后，脚本挂起，并且不再从Twitter接收消息。如果我删除了“ 最初没有单独的线程，因为我无法实现将所有内容包装在单独的线程中的结果，但结果是相同的 我做错了什么？ from telethon import TelegramClient, events, sync
from telethon.tl.types import InputChannel
import tweepy
import yaml
import sys
import coloredlogs, logging
import asyncio
import threading
impo
浏览 15提问于2021-04-11得票数 0
回答已采纳
1回答
使用Tweepy对流对象使用filter()函数获取401错误
python、twitter、jupyter、tweepy
以下是我在Jupyter Notebook中用来捕获和分析Twitter流数据的代码。虽然stream对象是在身份验证之后创建的，但我得到了401错误。身份验证凭据是正确的，并且我使用tweepy进行授权。有什么见解吗？
auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_token, access_token_secret)
print(auth)
<tweepy.auth.OAuthHandler object at 0x0000022B8450B288>
浏览 1提问于2020-04-28得票数 1
2回答
当用户使用Tweepy在tweets上发帖时，请通知
python、tweepy
我正在用tweepy和一个推特机器人玩。
我已经根据tweet中包含的单词(例如我的触发短语)成功地过滤了代码，执行如下操作：
myStreamListener = MyStreamListener()
myStream = tweepy.Stream(auth = api.auth, listener=MyStreamListener())
myStream.filter(track=['my trigger phrase'])
这工作得很好。
但是，当某个用户在tweets上(例如“某人”)时，我希望我的代码能够过滤。
我试过：
myStreamListener = MyS
浏览 0提问于2018-08-12得票数 7
回答已采纳
1回答
Tweepy中带有位置过滤器的流Twitter运行时间估计
python、twitter、geolocation、tweepy、time-estimation
问题已解决，请参阅后的解决方案
我需要帮助估计我的tweepy程序使用位置过滤器调用的运行时间。
在我开球后，它跑了20多分钟，比我预期的要长。我刚接触过，并且只使用了REST几天。在我看来，REST将在几秒钟内给我50个tweet，很简单。但是这个流请求需要更多的时间。我的程序没有死在我身上，也没有出现任何错误。所以我不知道是不是出了什么问题。如果是的话，请指出。
总之，如果你认为我的代码是正确的，你能提供一个运行时间的估计吗？如果你认为我的代码错了，你能帮我修一下吗？
提前谢谢你！
下面是代码：
# Import Tweepy, sys, sleep, credentials.py
imp
浏览 1提问于2017-03-10得票数 0
回答已采纳
1回答
在Python中使用kafka producer发送数据时出现问题(Jupyter Notebook)
python、apache-spark、apache-kafka、kafka-producer-api
我正在尝试使用Kafka，Python和Twitter创建一个大数据分析。我有一个推文的数据流，我只接受它们的标签。我的问题出在Kafka在Python中使用的生产者。我不能将我想要的数据发送到我创建的主题中，因为我看不到任何使用生产者发送变量内容的选项。 在https://kafka-python.readthedocs.io/en/master/usage.html中，我只能看到使用b'some_string'发送精确字符串的选项。但是我想把我从推特上取来的标签发送出去。我对Python了解不多，所以如果解决方案很明显，请原谅。 导入： from pyspark impo
浏览 55提问于2019-03-20得票数 0
2回答
为什么电视在试图从电报组中获取用户时会出现错误？
python、telegram、telegram-bot、telethon、mtproto
我正试着用电报机器人从一个群组中获得用户。为此，我正在使用python的telethon库。这是代码和完整的错误信息-
from telethon import TelegramClient, events
API_ID = 123
API_HASH = '##'
BOT_TOKEN ="##"
bot = TelegramClient('bot', API_ID, API_HASH)
bot.start(bot_token=BOT_TOKEN)
async def Get_Random():
users = await bot
浏览 12提问于2022-02-24得票数 3
1回答
使用Tweepy的InsecurePlatformWarning
python-2.7、twitter、tweepy、twitter-streaming-api、twitter-search
我在上使用python2.7.7。我从官方的Tweepy文档- 中复制了代码。
import tweepy
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)
a
浏览 8提问于2015-06-03得票数 0
回答已采纳
1回答
如何使用twitter V2来流tweet？
python、twitter、tweepy
我正在尝试使用twitter V.2来流tweet。但是我下面的在线教程使用了API v1。我看了文档，我知道我现在应该用(tweepy.StreamingClient)代替？但我找不到任何关于如何发送推特的例子。如何转换下面的代码以使其适用于API v2？
import tweepy
# API KEYS
bearer_token = ""
consumer_key = ''
consumer_secret = ''
access_token = ''
access_token_secret = ''
# a
浏览 9提问于2022-08-18得票数 0
1回答
如何从提及的推文中检索用户详细信息？
python、twitter、tweepy
我在创建一个机器人的过程中，读取所有提及的用户流推特时间表和相应的回复，但我似乎无法得到用户的详细信息谁发布了提及，以便回复，所有我收到的是提及的状态/文本。
我使用Python和Tweepy API来实现这一点：
import tweepy
from tweepy import Stream
consumer_key = '********'
consumer_secret = '********'
access_token = '***********'
access_secret = '*********'
auth =
浏览 0提问于2017-09-26得票数 0
1回答
Twitter如何获得用户的实时tweet
python、twitter、tweepy
是否有一种通过Twitter句柄或Twitter ID使用来获取实时tweet的方法？
我尝试过使用，但我只能通过关键字过滤tried：
import tweepy
import json
# Import the necessary methods from tweepy library
from tweepy.streaming import StreamListener
from tweepy import OAuthHandler
from tweepy import Stream
# Variables that contains the user credentials to
浏览 3提问于2016-03-10得票数 4
回答已采纳
1回答
Tweepy定位滤波器不工作
python、twitter、geolocation、location、tweepy
问题解决了，见接受后的解决方案
我试图收集50条来自特定地理区域的推文。我下面的代码将打印50条推特，但其中很多是“无”的坐标。这是否意味着这些“无”的推文不是从指定的区域生成的？你能解释一下这里发生了什么吗？以及如何从这个指定的地理区域收集50条推文？提前谢谢。
# Import Tweepy, sys, sleep, credentials.py
try:
import json
except ImportError:
import simplejson as json
import tweepy, sys
from time import sleep
from crede
浏览 1提问于2017-03-12得票数 3
回答已采纳
1回答
在Python中挖掘两个日期之间的推文
python、twitter
我想在一段时间内挖掘两个关键字的推文。我目前有下面的代码，但我如何添加它，使它只在两个日期之间的推文？(10/03/2016 - 10/07/2016)谢谢！
#Import the necessary methods from tweepy library
from tweepy.streaming import StreamListener
from tweepy import OAuthHandler
from tweepy import Stream
#Variables that contains the user credentials to access Twitter API
浏览 1提问于2016-10-09得票数 2
1回答
在没有应用程序的情况下访问Twitter流API
python、twitter、tweepy
我正在为一个小小的市场情绪项目编写一个Twitter程序，我正在利用Tweepy库在Pyhon做一些有趣的事情。然而，我对API访问和诸如此类的知识有限，这使得大多数Twitter文档变得有点神秘。我想知道一些事情，如果这不是提出这些问题的适当地点，请让我知道，以便我可以把它们寄到其他地方：
1)我没有我正在写的应用程序。如果没有流API，还可以访问吗？如果是这样的话，我如何申请消费者和访问令牌密钥，以便我可以使用Oauth2访问提要？
( 2)我是否有可能通过自己的推特( Twitter )上的所有资料访问自己的推特(Twitter)，然后跟踪大量我认为会有相关市场信息的人？
我现在有一个快
浏览 0提问于2013-05-20得票数 5
回答已采纳
1回答
带有Python的Twitter流API
python、twitter、location、tweepy、twitter-streaming-api
我一直在使用Tweepy库玩Twitter流API。一开始，我跟踪自己的账户，上传自己的推文，效果很好。
然后，我尝试发送一个相当大的区域的tweet (30，-85,31，-84)，我最初似乎没有收到任何数据。然后我开始收到“位置删除通知”，或者“scrub_geo”消息，从那以后我才收到这些消息。我将代码更改为以前工作的后续代码，但我继续接收“scrub_geo”消息，而不是从我的配置文件中接收状态。
下面是我正在使用的脚本：
# Import the necessary methods from tweepy library
from tweepy.streaming import St
浏览 1提问于2015-10-03得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
