Asynchronous Azure Table PointQueries in Python

async_query.py

import asyncio
from azure.data.tables import TableClient

client = TableClient.from_connection_string(conn_str='foo', table_name='bar')

async def run_query(partition_key, row_key):
   return client.query_entity(partition_key, row_key)

async def gather_queries(partition_key, row_key_base, substitutions):
  return asyncio.gather(*[run_query(partition_key, row_key % subst) for subst in substitutions])
                          

substitutions = ['1', '2', '3', '4', '5']
partition_key = 'partition_key'
row_key_base = 'rowkey_%s'
results = asyncio.run(gather_queries(partition_key, row_key, substitutions)).result()