我正在制作一个实用程序,我需要在其中提取用户的推文并将它们存储在数据库中。 Twitter API 在一次调用中仅发送 20 条推文,要检索更多推文,您需要一次翻阅 20 条推文。因此,我不想从 Twitter API 同步读取推文并等待插入数据库,而是想异步启动数据库插入以优化流程。
如何使用 Python 和 Mysql 实现此目的?
伪代码可以写成(不检查语法有效性):-
def readTweets():
x=0
while true:
tweets= twitterAPI.getusertimeline(id='twitterUser',count=20,page=x)
#Need to know how to call the below function asynchronously
callDBSaveAsynchronously(tweets)
if len(tweets) < 20: break
x=x+1
def callDBSaveAsynchronously(tweets):
for tweet in tweets:
mysqldb.insertTweet(tweet)
提前致谢!
最佳答案
有一个名为 ultramysql 的第三方 MySQL 驱动程序可以利用 gevent用于异步插入。你可以这样避免线程。它对我最近的一个项目非常有用。
关于python - 异步数据库插入——python + mysql,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/16928914/