如何通过twisted实现数据库异步插入？
1. 导入adbapi
2. 生成数据库连接池
3. 执行数据数据库插入操作
4. 打印错误信息，并排错
#!/usr/bin/python3 __author__ = 'beimenchuixue'__blog__ = 'http://mit() try: # 生成连接池 db_conn = adbapi.ConnectionPool('pymysql', **db_settings) # 通过连接池执行具体的sql操作，返回一个对象 query = db_conn.runInteraction(go_insert, insert_sql) # 对错误信息进行提示处理 query.addCallbacks(handle_error) except Exception as e: print(e) # 定时，给4秒时间让twisted异步框架完成数据库插入异步操作，没有定时什么都不会做 reactor.callLater(4, reactor.stop) reactor.run()以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。
最新文章
热门文章
猜你喜欢
