aiocsv_async_csv_read_write_with_aiofiles.py

1import asyncio
2import csv
3import aiofiles
4from aiocsv import AsyncReader, AsyncDictReader, AsyncWriter, AsyncDictWriter
5
6async def main():
7    # Writing
8    async with aiofiles.open("test.csv", mode="w", encoding="utf-8", newline="") as afp:
9        writer = AsyncWriter(afp, quoting=csv.QUOTE_ALL)
10        await writer.writerow(["name", "age"])
11        await writer.writerows([["alice", 30], ["bob", 42]])
12
13    # Reading
14    async with aiofiles.open("test.csv", mode="r", encoding="utf-8", newline="") as afp:
15        async for row in AsyncReader(afp):
16            print(row)  # ['name', 'age'], ['alice', '30'], ['bob', '42']
17
18    # DictReading
19    async with aiofiles.open("test.csv", mode="r", encoding="utf-8", newline="") as afp:
20        async for row in AsyncDictReader(afp):
21            print(row)  # {"name": "alice", "age": "30"}, {"name": "bob", "age": "42"}
22
23if __name__ == "__main__":
24    asyncio.run(main())