test: asyncio

routes/data.py

@@ -55,7 +55,7 @@ async def update_entire_rsi():
 )
 async def update_entire_macd():
     asyncio.create_task(Indicator.update_entire_macd())
-    return None
+    return {"message": "Updated"}
 
 
 @router.post(

services/indicator.py

@@ -4,11 +4,11 @@ import pandas as pd
 import numpy as np
 from vnstock import longterm_ohlc_data
 from pymongo import MongoClient, ASCENDING, DESCENDING
-from utils.config import DATE_FORMAT, VN100_URL
+from utils.config import DATE_FORMAT, VN100_URL, HSX_HEADER
 from .utils import Utility
 import os
-# from dotenv import load_dotenv
-# load_dotenv()
+from dotenv import load_dotenv
+load_dotenv()
 
 PREFIX = "https://www.hsx.vn/Modules/Chart/StaticChart/"
 TIME = {"1m": 2, "3m": 3, "6m": 4, "1y": 5, "2y": 6, "5y": 7}
@@ -41,7 +41,7 @@ class Indicator:
                 newest_record = collection.find_one(sort=[("_id", ASCENDING)])
                 lst_symbols = list(newest_record.keys())[2:]
             elif source == "hsx":
-                data = requests.get(VN100_URL).json()
+                data = requests.get(VN100_URL, headers=HSX_HEADER).json()
                 data = data["rows"]
                 for value in data:
                     lst_symbols.append(value["cell"][2].strip())
@@ -292,7 +292,7 @@ class Indicator:
                 cnt += 1
                 url = PREFIX + INDICATORS["RSI"] \
                     + f"?stockSymbol={symbol}&rangeSelector=3&periods=14"
-                data = requests.get(url).json()
+                data = requests.get(url, headers=HSX_HEADER).json()
                 rsi_df = pd.DataFrame(data["SeriesColection"][0]["Points"])
                 if get_time:
                     lst_values["time"] = \
@@ -362,7 +362,7 @@ class Indicator:
         return stoch_rsi_k.rolling(window=d).mean()
 
     @staticmethod
-    def update_entire_macd() -> None:
+    async def update_entire_macd() -> None:
         global updating_macd
         if updating_macd:
             return
@@ -386,7 +386,7 @@ class Indicator:
                 cnt += 1
                 url = PREFIX + INDICATORS["MACD"] \
                     + f"?stockSymbol={symbol}&rangeSelector=4&fastPeriod=12&slowPeriod=26&signalPeriod=9"
-                data = requests.get(url).json()
+                data = requests.get(url, headers=HSX_HEADER).json()
                 rsi_df = pd.DataFrame(
                     data["SeriesColection"][0]["Points"]).tail(20)
                 if get_time:

utils/config.py

@@ -1,5 +1,21 @@
 DATE_FORMAT = "%Y-%m-%d"
-tcbs_headers = {
+HSX_HEADER = {
+    "Accept": "*/*",
+    "Accept-Encoding": "gzip, deflate, br",
+    "Accept-Language": "en-US,en;q=0.9",
+    "Connection": "keep-alive",
+    "Host": "www.hsx.vn",
+    "Referer": "https://www.hsx.vn/modules/Chart/StaticChart/technicalchart?fid=138445b111554631a5e8a322f10337ee",
+    "Sec-Ch-Ua": "\"Not A(Brand\";v=\"99\", \"Microsoft Edge\";v=\"121\", \"Chromium\";v=\"121\"",
+    "Sec-Ch-Ua-Mobile": "?0",
+    "Sec-Ch-Ua-Platform": "\"Windows\"",
+    "Sec-Fetch-Dest": "empty",
+    "Sec-Fetch-Mode": "cors",
+    "Sec-Fetch-Site": "same-origin",
+    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/121.0.0.0 Safari/537.36 Edg/121.0.0.0",
+    "X-Requested-With": "XMLHttpRequest",
+}
+TCBS_HEADER = {
   'sec-ch-ua': '"Google Chrome";v="119", "Chromium";v="119", "Not?A_Brand";v="24"',
   'DNT': '1',
   'Accept-language': 'vi',