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

bugfixing remove old quotes

Browse Source
This commit is contained in:
MuslemRahimi 2024-09-17 00:08:45 +02:00
parent a53f3ae87b
commit 652533d73f
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
app/cron_quote.py
View File

@ -11,6 +11,17 @@ load_dotenv()
api_key = os.getenv('FMP_API_KEY') api_key = os.getenv('FMP_API_KEY')
# Function to delete all files in a directory
def delete_files_in_directory(directory):
for filename in os.listdir(directory):
file_path = os.path.join(directory, filename)
try:
if os.path.isfile(file_path):
os.remove(file_path)
except Exception as e:
print(f"Failed to delete {file_path}. Reason: {e}")
async def get_quote_of_stocks(ticker_list): async def get_quote_of_stocks(ticker_list):
ticker_str = ','.join(ticker_list) ticker_str = ','.join(ticker_list)
async with aiohttp.ClientSession() as session: async with aiohttp.ClientSession() as session:
@ -100,6 +111,7 @@ async def run():
#print(f"Saved data for {symbol}.") #print(f"Saved data for {symbol}.")
if is_market_closed == True: if is_market_closed == True:
delete_files_in_directory("json/pre-post-quote")
latest_quote = await get_pre_post_quote_of_stocks(chunk) latest_quote = await get_pre_post_quote_of_stocks(chunk)
for item in latest_quote: for item in latest_quote:
symbol = item['symbol'] symbol = item['symbol']