如何在Python中读取CSV然后发布批量API调用

在Python中读取CSV文件并发布批量API调用是一个常见的任务，通常用于数据导入或数据同步。以下是实现这一任务的步骤和相关概念：

基础概念

CSV文件：逗号分隔值（Comma-Separated Values）文件，是一种常见的数据交换格式。
API调用：应用程序编程接口（Application Programming Interface），允许不同的软件应用之间进行交互。
批量API调用：一次性发送多个API请求，以提高效率。

类型

同步API调用：等待每个请求完成后再发送下一个请求。
异步API调用：同时发送多个请求，不等待每个请求完成。

应用场景

数据导入：将CSV文件中的数据导入到数据库或第三方服务。
数据同步：定期将数据从一个系统同步到另一个系统。

示例代码

以下是一个示例代码，展示如何使用Python读取CSV文件并发布批量API调用：

import csv
import requests

# 假设CSV文件名为data.csv，API端点为https://api.example.com/data
csv_file_path = 'data.csv'
api_endpoint = 'https://api.example.com/data'

# 读取CSV文件
def read_csv(file_path):
    data = []
    with open(file_path, newline='') as csvfile:
        reader = csv.DictReader(csvfile)
        for row in reader:
            data.append(row)
    return data

# 发布批量API调用
def batch_api_call(data, endpoint):
    headers = {
        'Content-Type': 'application/json'
    }
    batch_size = 10  # 每批处理的请求数量
    for i in range(0, len(data), batch_size):
        batch_data = data[i:i + batch_size]
        response = requests.post(endpoint, json=batch_data, headers=headers)
        if response.status_code == 200:
            print(f"Batch {i//batch_size + 1} processed successfully")
        else:
            print(f"Batch {i//batch_size + 1} failed with status code {response.status_code}")

# 主函数
def main():
    data = read_csv(csv_file_path)
    batch_api_call(data, api_endpoint)

if __name__ == "__main__":
    main()