twscrape

twscrape

异步Twitter数据抓取库支持多账户并发

twscrape是一个开源的Twitter数据抓取库,集成了搜索和GraphQL API功能。它采用异步设计支持并行抓取,实现了自动登录、会话管理和账户轮换机制来应对API限制。该库可获取用户和推文等多种数据,并提供命令行界面便于使用。twscrape主要面向需要批量采集Twitter数据的研究和开发人员。

twscrapeTwitter API数据抓取Python库异步编程Github开源项目

twscrape

<div align="center">

<img src="https://badgen.net/pypi/v/twscrape" alt="version" /> <img src="https://badgen.net/pypi/python/twscrape" alt="py versions" /> <img src="https://badgen.net/pypi/dm/twscrape" alt="downloads" /> <img src="https://badgen.net/github/license/vladkens/twscrape" alt="license" /> <img src="https://badgen.net/static/-/buy%20me%20a%20coffee/ff813f?icon=buymeacoffee&label" alt="donate" />

</div>

Twitter GraphQL API implementation with SNScrape data models.

<div align="center"> <img src=".github/example.png" alt="example of cli usage" height="400px"> </div>

Install

pip install twscrape

Or development version:

pip install git+https://github.com/vladkens/twscrape.git

Features

  • Support both Search & GraphQL Twitter API
  • Async/Await functions (can run multiple scrapers in parallel at the same time)
  • Login flow (with receiving verification code from email)
  • Saving/restoring account sessions
  • Raw Twitter API responses & SNScrape models
  • Automatic account switching to smooth Twitter API rate limits

Usage

Since this project works through an authorized API, accounts need to be added. You can register and add an account yourself. You can also google sites that provide these things.

The email password is needed to get the code to log in to the account automatically (via imap protocol).

Data models:

import asyncio from twscrape import API, gather from twscrape.logger import set_log_level async def main(): api = API() # or API("path-to.db") - default is `accounts.db` # ADD ACCOUNTS (for CLI usage see BELOW) await api.pool.add_account("user1", "pass1", "u1@example.com", "mail_pass1") await api.pool.add_account("user2", "pass2", "u2@example.com", "mail_pass2") await api.pool.login_all() # or add account with COOKIES (with cookies login not required) cookies = "abc=12; ct0=xyz" # or '{"abc": "12", "ct0": "xyz"}' await api.pool.add_account("user3", "pass3", "u3@mail.com", "mail_pass3", cookies=cookies) # API USAGE # search (latest tab) await gather(api.search("elon musk", limit=20)) # list[Tweet] # change search tab (product), can be: Top, Latest (default), Media await gather(api.search("elon musk", limit=20, kv={"product": "Top"})) # tweet info tweet_id = 20 await api.tweet_details(tweet_id) # Tweet await gather(api.retweeters(tweet_id, limit=20)) # list[User] # Note: this method have small pagination from X side, like 5 tweets per query await gather(api.tweet_replies(tweet_id, limit=20)) # list[Tweet] # get user by login user_login = "xdevelopers" await api.user_by_login(user_login) # User # user info user_id = 2244994945 await api.user_by_id(user_id) # User await gather(api.following(user_id, limit=20)) # list[User] await gather(api.followers(user_id, limit=20)) # list[User] await gather(api.verified_followers(user_id, limit=20)) # list[User] await gather(api.subscriptions(user_id, limit=20)) # list[User] await gather(api.user_tweets(user_id, limit=20)) # list[Tweet] await gather(api.user_tweets_and_replies(user_id, limit=20)) # list[Tweet] # list info list_id = 123456789 await gather(api.list_timeline(list_id)) # NOTE 1: gather is a helper function to receive all data as list, FOR can be used as well: async for tweet in api.search("elon musk"): print(tweet.id, tweet.user.username, tweet.rawContent) # tweet is `Tweet` object # NOTE 2: all methods have `raw` version (returns `httpx.Response` object): async for rep in api.search_raw("elon musk"): print(rep.status_code, rep.json()) # rep is `httpx.Response` object # change log level, default info set_log_level("DEBUG") # Tweet & User model can be converted to regular dict or json, e.g.: doc = await api.user_by_id(user_id) # User doc.dict() # -> python dict doc.json() # -> json string if __name__ == "__main__": asyncio.run(main())

Depraceted API methods (no more available in X)

  • favoriters (ref)
  • liked_tweets (ref)

Stoping iteration with break

In order to correctly release an account in case of break in loop, a special syntax must be used. Otherwise, Python's events loop will release lock on the account sometime in the future. See explanation here.

from contextlib import aclosing async with aclosing(api.search("elon musk")) as gen: async for tweet in gen: if tweet.id < 200: break

CLI

Get help on CLI commands

# show all commands twscrape # help on specific comand twscrape search --help

Add accounts

To add accounts use add_accounts command. Command syntax is:

twscrape add_accounts <file_path> <line_format>

Where: <line_format> is format of line if accounts file splited by delimeter. Possible tokens:

  • username – required
  • password – required
  • email – required
  • email_password – to receive email code (you can use --manual mode to get code)
  • cookies – can be any parsable format (string, json, base64 string, etc)
  • _ – skip column from parse

Tokens should be splited by delimeter, usually ":" used.

Example:

I have account files named order-12345.txt with format:

username:password:email:email password:user_agent:cookies

Command to add accounts will be (user_agent column skiped with _):

twscrape add_accounts ./order-12345.txt username:password:email:email_password:_:cookies

Login accounts

Note: If you added accounts with cookies, login not required.

Run:

twscrape login_accounts

twscrape will start login flow for each new account. If X will ask to verify email and you provided email_password in add_account, then twscrape will try to receive verification code by IMAP protocol. After success login account cookies will be saved to db file for future use.

Manual email verification

In case your email provider not support IMAP protocol (ProtonMail, Tutanota, etc) or IMAP is disabled in settings, you can enter email verification code manually. To do this run login command with --manual flag.

Example:

twscrape login_accounts --manual twscrape relogin user1 user2 --manual twscrape relogin_failed --manual

Get list of accounts and their statuses

twscrape accounts # Output: # username logged_in active last_used total_req error_msg # user1 True True 2023-05-20 03:20:40 100 None # user2 True True 2023-05-20 03:25:45 120 None # user3 False False None 120 Login error

Re-login accounts

It is possible to re-login specific accounts:

twscrape relogin user1 user2

Or retry login for all failed logins:

twscrape relogin_failed

Use different accounts file

Useful if using a different set of accounts for different actions

twscrape --db test-accounts.db <command>

Search commands

twscrape search "QUERY" --limit=20 twscrape tweet_details TWEET_ID twscrape tweet_replies TWEET_ID --limit=20 twscrape retweeters TWEET_ID --limit=20 twscrape user_by_id USER_ID twscrape user_by_login USERNAME twscrape following USER_ID --limit=20 twscrape followers USER_ID --limit=20 twscrape verified_followers USER_ID --limit=20 twscrape subscriptions USER_ID --limit=20 twscrape user_tweets USER_ID --limit=20 twscrape user_tweets_and_replies USER_ID --limit=20

The default output is in the console (stdout), one document per line. So it can be redirected to the file.

twscrape search "elon mask lang:es" --limit=20 > data.txt

By default, parsed data is returned. The original tweet responses can be retrieved with --raw flag.

twscrape search "elon mask lang:es" --limit=20 --raw

Proxy

There are few options to use proxies.

  1. You can add proxy per account
proxy = "http://login:pass@example.com:8080" await api.pool.add_account("user4", "pass4", "u4@mail.com", "mail_pass4", proxy=proxy)
  1. You can use global proxy for all accounts
proxy = "http://login:pass@example.com:8080" api = API(proxy=proxy) doc = await api.user_by_login("elonmusk")
  1. Use can set proxy with environemt variable TWS_RPOXY:
TWS_PROXY=socks5://user:pass@127.0.0.1:1080 twscrape user_by_login elonmusk
  1. You can change proxy any time like:
api.proxy = "socks5://user:pass@127.0.0.1:1080" doc = await api.user_by_login("elonmusk") # new proxy will be used api.proxy = None doc = await api.user_by_login("elonmusk") # no proxy used
  1. Proxy priorities
  • api.proxy have top priority
  • env.proxy will be used if api.proxy is None
  • acc.proxy have lowest priotity

So if you want to use proxy PER ACCOUNT, do NOT override proxy with env variable or by passing proxy param to API.

Note: If proxy not working, exception will be raised from API class.

Environment variables

  • TWS_WAIT_EMAIL_CODE – timeout for email verification code during login (default: 30, in seconds)
  • TWS_RAISE_WHEN_NO_ACCOUNT – raise NoAccountError exception when no available accounts right now, instead of waiting for availability (default: false, possible value: false / 0 / true / 1)

Limitations

After 1 July 2023 Twitter introduced new limits and still continue to update it periodically.

The basic behaviour is as follows:

  • the request limit is updated every 15 minutes for each endpoint individually
  • e.g. each account have 50 search requests / 15 min, 50 profile requests / 15 min, etc.

API data limits:

  • user_tweets & user_tweets_and_replies – can return ~3200 tweets maximum

Articles

See also

编辑推荐精选

Vora

Vora

免费创建高清无水印Sora视频

Vora是一个免费创建高清无水印Sora视频的AI工具

Refly.AI

Refly.AI

最适合小白的AI自动化工作流平台

无需编码,轻松生成可复用、可变现的AI自动化工作流

酷表ChatExcel

酷表ChatExcel

大模型驱动的Excel数据处理工具

基于大模型交互的表格处理系统,允许用户通过对话方式完成数据整理和可视化分析。系统采用机器学习算法解析用户指令,自动执行排序、公式计算和数据透视等操作,支持多种文件格式导入导出。数据处理响应速度保持在0.8秒以内,支持超过100万行数据的即时分析。

AI工具使用教程AI营销产品酷表ChatExcelAI智能客服
TRAE编程

TRAE编程

AI辅助编程,代码自动修复

Trae是一种自适应的集成开发环境(IDE),通过自动化和多元协作改变开发流程。利用Trae,团队能够更快速、精确地编写和部署代码,从而提高编程效率和项目交付速度。Trae具备上下文感知和代码自动完成功能,是提升开发效率的理想工具。

热门AI工具生产力协作转型TraeAI IDE
AIWritePaper论文写作

AIWritePaper论文写作

AI论文写作指导平台

AIWritePaper论文写作是一站式AI论文写作辅助工具,简化了选题、文献检索至论文撰写的整个过程。通过简单设定,平台可快速生成高质量论文大纲和全文,配合图表、参考文献等一应俱全,同时提供开题报告和答辩PPT等增值服务,保障数据安全,有效提升写作效率和论文质量。

数据安全AI助手热门AI工具AI辅助写作AI论文工具论文写作智能生成大纲
博思AIPPT

博思AIPPT

AI一键生成PPT,就用博思AIPPT!

博思AIPPT,新一代的AI生成PPT平台,支持智能生成PPT、AI美化PPT、文本&链接生成PPT、导入Word/PDF/Markdown文档生成PPT等,内置海量精美PPT模板,涵盖商务、教育、科技等不同风格,同时针对每个页面提供多种版式,一键自适应切换,完美适配各种办公场景。

热门AI工具AI办公办公工具智能排版AI生成PPT博思AIPPT海量精品模板AI创作
潮际好麦

潮际好麦

AI赋能电商视觉革命,一站式智能商拍平台

潮际好麦深耕服装行业,是国内AI试衣效果最好的软件。使用先进AIGC能力为电商卖家批量提供优质的、低成本的商拍图。合作品牌有Shein、Lazada、安踏、百丽等65个国内外头部品牌,以及国内10万+淘宝、天猫、京东等主流平台的品牌商家,为卖家节省将近85%的出图成本,提升约3倍出图效率,让品牌能够快速上架。

iTerms

iTerms

企业专属的AI法律顾问

iTerms是法大大集团旗下法律子品牌,基于最先进的大语言模型(LLM)、专业的法律知识库和强大的智能体架构,帮助企业扫清合规障碍,筑牢风控防线,成为您企业专属的AI法律顾问。

SimilarWeb流量提升

SimilarWeb流量提升

稳定高效的流量提升解决方案,助力品牌曝光

稳定高效的流量提升解决方案,助力品牌曝光

Sora2视频免费生成

Sora2视频免费生成

最新版Sora2模型免费使用,一键生成无水印视频

最新版Sora2模型免费使用,一键生成无水印视频

下拉加载更多