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进行异步插入。你可以这样避免线程。它对我最近的一个项目非常有用。