要使用 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())