AmineTMIRI/backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update one day price

Browse Source
This commit is contained in:
MuslemRahimi 2025-04-07 15:50:20 +02:00
parent b9380c3d7c
commit 05a2ce5f88
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/cron_one_day_price.py
View File

@ -88,7 +88,7 @@ async def get_todays_data(ticker, semaphore):
async def run(): async def run():
# Create a semaphore to limit the number of concurrent connections # Create a semaphore to limit the number of concurrent connections
# Adjust this number based on your system's limits # Adjust this number based on your system's limits
connection_limit = 50 connection_limit = 1500
semaphore = asyncio.Semaphore(connection_limit) semaphore = asyncio.Semaphore(connection_limit)
con = sqlite3.connect('stocks.db') con = sqlite3.connect('stocks.db')
@ -126,7 +126,7 @@ async def run():
total_symbols = stocks_symbols + etf_symbols + index_symbols total_symbols = stocks_symbols + etf_symbols + index_symbols
# Reduce chunk size to avoid too many concurrent requests # Reduce chunk size to avoid too many concurrent requests
chunk_size = 100 chunk_size = 250
for i in range(0, len(total_symbols), chunk_size): for i in range(0, len(total_symbols), chunk_size):
symbols_chunk = total_symbols[i:i+chunk_size] symbols_chunk = total_symbols[i:i+chunk_size]
await fetch_and_save_symbols_data(symbols_chunk, semaphore) await fetch_and_save_symbols_data(symbols_chunk, semaphore)