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

bugfixing volume

Browse Source
This commit is contained in:
MuslemRahimi 2024-09-22 01:25:50 +02:00
parent 7bddf19976
commit 937086c420
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
app/cron_historical_price.py
View File

@ -41,7 +41,10 @@ async def get_historical_data(ticker, query_con, session):
for response in [response_1w, response_1m]: for response in [response_1w, response_1m]:
json_data = await response.json() json_data = await response.json()
df = pd.DataFrame(json_data).iloc[::-1].reset_index(drop=True) df = pd.DataFrame(json_data).iloc[::-1].reset_index(drop=True)
df = df.drop(['volume'], axis=1) try:
df = df.drop(['volume'], axis=1)
except:
pass
df = df.round(2).rename(columns={"date": "time"}) df = df.round(2).rename(columns={"date": "time"})
data.append(df.to_json(orient="records")) data.append(df.to_json(orient="records"))
@ -56,7 +59,6 @@ async def get_historical_data(ticker, query_con, session):
df_1y = pd.read_sql_query(query, query_con, params=(start_date_1y, end_date)).round(2).rename(columns={"date": "time"}) df_1y = pd.read_sql_query(query, query_con, params=(start_date_1y, end_date)).round(2).rename(columns={"date": "time"})
df_max = pd.read_sql_query(query, query_con, params=(start_date_max, end_date)).round(2).rename(columns={"date": "time"}) df_max = pd.read_sql_query(query, query_con, params=(start_date_max, end_date)).round(2).rename(columns={"date": "time"})
async with aiofiles.open(f"json/historical-price/one-week/{ticker}.json", 'w') as file: async with aiofiles.open(f"json/historical-price/one-week/{ticker}.json", 'w') as file:
res = ujson.loads(data[0]) if data else [] res = ujson.loads(data[0]) if data else []
await file.write(ujson.dumps(res)) await file.write(ujson.dumps(res))
@ -128,7 +130,6 @@ try:
start_date_max = datetime(1970, 1, 1).strftime("%Y-%m-%d") start_date_max = datetime(1970, 1, 1).strftime("%Y-%m-%d")
end_date = end_date.strftime("%Y-%m-%d") end_date = end_date.strftime("%Y-%m-%d")
print(start_date_max, end_date)
chunk_size = 250 chunk_size = 250
asyncio.run(run()) asyncio.run(run())