Skip to content

P
PyFund
Commit 0c9e3217 authored by 杨明橙's avatar 杨明橙
Browse files
Options

修改行情数据更新

parent 3b49a589
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 0 deletions
service/price.py
View file @ 0c9e3217
...@@ -186,6 +186,7 @@ class CMCPrice: ...@@ -186,6 +186,7 @@ class CMCPrice:
async def start_init_ohlcv(self, symbol): async def start_init_ohlcv(self, symbol):
await self.init() await self.init()
await self.load_base_coins()
start_time = await self.query_added_date(symbol) start_time = await self.query_added_date(symbol)
logger.info(f'[开始初始化] [{symbol}]') logger.info(f'[开始初始化] [{symbol}]')
await self.start_task(symbol, start_time) await self.start_task(symbol, start_time)
...@@ -193,6 +194,7 @@ class CMCPrice: ...@@ -193,6 +194,7 @@ class CMCPrice:
async def start_update_ohlcv(self, symbol=None): async def start_update_ohlcv(self, symbol=None):
await self.init() await self.init()
await self.load_base_coins()
symbol_list = [symbol] if symbol else self.base_coins symbol_list = [symbol] if symbol else self.base_coins
for symbol in symbol_list: for symbol in symbol_list:
logger.info(f'[开始更新] [{symbol}]') logger.info(f'[开始更新] [{symbol}]')
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment