forked from PatrickAlphaC/async-python
-
Notifications
You must be signed in to change notification settings - Fork 0
/
async_run.py
29 lines (26 loc) · 916 Bytes
/
async_run.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
import asyncio
import aiohttp
import os
import time
# To work with the .env file
from dotenv import load_dotenv
load_dotenv()
api_key = os.getenv('ALPHAVANTAGE_API_KEY')
url = 'https://www.alphavantage.co/query?function=OVERVIEW&symbol={}&apikey={}'
symbols = ['AAPL', 'GOOG', 'TSLA', 'MSFT', 'AAPL']
results = []
start = time.time()
async def get_symbols():
async with aiohttp.ClientSession() as session:
for symbol in symbols:
print('Working on symbol {}'.format(symbol))
response = await asyncio.create_task(session.get(url.format(symbol, api_key), ssl=False))
results.append(await response.json())
asyncio.run(get_symbols())
# loop = asyncio.get_event_loop()
# loop.run_until_complete(get_symbols())
# loop.close()
end = time.time()
total_time = end - start
print("It took {} seconds to make {} API calls".format(total_time, len(symbols)))
print('You did it!')