python - 异步数据库插入——python + mysql

Question

我正在制作一个实用程序，我需要在其中提取用户的推文并将它们存储在数据库中。 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)

 

提前致谢!

Answer 1

有一个名为 ultramysql 的第三方 MySQL 驱动程序可以利用 gevent用于异步插入。你可以这样避免线程。它对我最近的一个项目非常有用。