|
|
@@ -9,7 +9,7 @@ import urllib.parse
|
|
|
hug.API(__name__).http.output_format = hug.output_format.json
|
|
|
|
|
|
# 填写路透的key
|
|
|
-key = ""
|
|
|
+key = "8e1de59e14fb4bbfaa40259941948345f6bbe7e6"
|
|
|
|
|
|
|
|
|
@hug.get('/hz_server')
|
|
|
@@ -29,6 +29,11 @@ def GetEdbDataFromEk(EdbCode, StartDate, EndDate ,Frequency="daily"):
|
|
|
if Frequency == "":
|
|
|
Frequency = "daily"
|
|
|
data = ek.get_timeseries(EdbCode, fields='*', start_date=StartDate, end_date=EndDate, interval=Frequency)
|
|
|
+ print(data)
|
|
|
+
|
|
|
+ # data.index = pd.to_datetime(data.index).strftime('%Y-%m-%d')
|
|
|
+ data.index = pd.to_datetime(data.index).tz_localize("UTC")
|
|
|
+
|
|
|
# print("result start\n", data)
|
|
|
if data is None:
|
|
|
print("数据查询失败：", data)
|
|
|
@@ -39,12 +44,20 @@ def GetEdbDataFromEk(EdbCode, StartDate, EndDate ,Frequency="daily"):
|
|
|
data = data.groupby(data.index).first()
|
|
|
# print("结束去重")
|
|
|
# print(data)
|
|
|
-
|
|
|
- # print("result end")
|
|
|
data_json = data.to_json()
|
|
|
result = json.loads(data_json)
|
|
|
+ #
|
|
|
+ # json_data = data.to_json(orient='records', date_format='epoch', date_unit='ms')
|
|
|
+ # print(json_data)
|
|
|
return result
|
|
|
|
|
|
+ # result = {
|
|
|
+ # "CLOSE": data["CLOSE"].to_dict(),
|
|
|
+ # }
|
|
|
+
|
|
|
+ # json_output = json.dumps(result,indent=2)
|
|
|
+ # return json_output
|
|
|
+
|
|
|
|
|
|
if __name__ == "__main__":
|
|
|
ek.set_app_key(key)
|
