调用DynamoDB查询，然后将结果写入s3存储桶:如何使用异步等待简化此代码？

import asyncio
import aioboto3

async def query_dynamodb():
    dynamodb = await aioboto3.resource('dynamodb').__aenter__()
    table = dynamodb.Table('your_table_name')
    response = await table.query(
        KeyConditionExpression=Key('your_key').eq('your_value')
    ).__aenter__()
    return response['Items']

async def write_to_s3(data):
    s3 = await aioboto3.resource('s3').__aenter__()
    bucket = s3.Bucket('your_bucket_name')
    await bucket.put_object(
        Key='your_object_key',
        Body=data
    )

async def main():
    dynamodb_result = await query_dynamodb()
    await write_to_s3(dynamodb_result)

# 使用异步事件循环运行主函数
loop = asyncio.get_event_loop()
loop.run_until_complete(main())