python async

要使用 Python 的 async 特性编写一个代码，以交替使用两个 AI API 处理数据，您可以按照以下步骤进行。假设这两个 AI API 的调用是异步的，并且我们需要在两个 API 之间轮流处理一组数据。

import asyncio
import aiohttp

async def call_api_1(data):
async with aiohttp.ClientSession() as session:
async with session.post(‘https://api1.example.com/endpoint’, json=data) as response:
result = await response.json()
return result

async def call_api_2(data):
async with aiohttp.ClientSession() as session:
async with session.post(‘https://api2.example.com/endpoint’, json=data) as response:
result = await response.json()
return result

async def process_data(data_list):
results = []
for i, data in enumerate(data_list):
if i % 2 == 0:
result = await call_api_1(data)
else:
result = await call_api_2(data)
results.append(result)
return results

async def main():
data_list = [{“input”: “data1”}, {“input”: “data2”}, {“input”: “data3”}, {“input”: “data4”}]
results = await process_data(data_list)
for i, result in enumerate(results):
print(f"Result from API {1 if i % 2 == 0 else 2}: {result}")

运行主函数

asyncio.run(main())