From 7bddf199766158696872df8bceca645f975bab76 Mon Sep 17 00:00:00 2001 From: MuslemRahimi Date: Sat, 21 Sep 2024 18:39:50 +0200 Subject: [PATCH] update --- app/cron_ta_rating.py | 51 +++++++++++++++++++++++-------------------- 1 file changed, 27 insertions(+), 24 deletions(-) diff --git a/app/cron_ta_rating.py b/app/cron_ta_rating.py index 499f33f..d393a3e 100755 --- a/app/cron_ta_rating.py +++ b/app/cron_ta_rating.py @@ -38,31 +38,34 @@ async def run(): total_symbols = stocks_symbols + etf_symbols + crypto_symbols for symbol in tqdm(total_symbols): - table_name = None - if symbol in etf_symbols: # Fixed variable name from symbols to symbol - query_con = etf_con - elif symbol in crypto_symbols: - query_con = crypto_con - elif symbol in stocks_symbols: - query_con = con - - query_template = """ - SELECT - date, open, high, low, close, volume - FROM - "{symbol}" - WHERE - date BETWEEN ? AND ? - """ - query = query_template.format(symbol=symbol) - df = pd.read_sql_query(query,query_con, params=(start_date, end_date)) - try: - # Assuming rating_model and save_quote_as_json are defined elsewhere - res_dict = rating_model(df).ta_rating() - await save_ta_rating(symbol, res_dict) - except Exception as e: - print(e) + table_name = None + if symbol in etf_symbols: # Fixed variable name from symbols to symbol + query_con = etf_con + elif symbol in crypto_symbols: + query_con = crypto_con + elif symbol in stocks_symbols: + query_con = con + + query_template = """ + SELECT + date, open, high, low, close, volume + FROM + "{symbol}" + WHERE + date BETWEEN ? AND ? + """ + query = query_template.format(symbol=symbol) + df = pd.read_sql_query(query,query_con, params=(start_date, end_date)) + + try: + # Assuming rating_model and save_quote_as_json are defined elsewhere + res_dict = rating_model(df).ta_rating() + await save_ta_rating(symbol, res_dict) + except Exception as e: + print(e) + except: + pass con.close()