Python如何实现异步并发查询MySQL并调用API灌数据，同时确保数据安全？

本文共计1158个文字，预计阅读时间需要5分钟。

回顾前期内容，上一篇文章已编写了异步并发API请求的完整数据。本章我们将继续编写异步并发加锁，确保数据安全。由于服务架构重构，本次优化包括表结构优化和重构，带来的任务是确保以下需求：

确保数据安全、实战任务及本次重构带来的任务需求。

前情回顾

上一篇文章已经编写了异步并发API请求灌数据，那么本章节我们来继续编写异步并发加锁，保证数据安全

实战任务

本次因为服务架构重构，表优化、重构，带来的任务就是需要从原来的mysql数据库中，读取原表数据（部分存在多张关联查询）然后通过调用API的服务方式灌入新的数据库表中（包含mysql、mongodb）。

执行流程如下

那么根据流程所需要的功能，需要以下的实例进行支撑：
1.并发实例
2.查询数据实例
3.执行post请求实例

目标：循环查询处理并发数据，并且加锁保证数据安全

给查询数据表添加​​is_import​​​字段，在mysql表中添加查询标识，插入成功则为​​1​​​，无插入则为​​0​​

然后初始化 ​​is_import = 0​​ 即可，下面来给我们之前的model方法的查询中添加条件查询。