From 1764036d81cdb3a81de265cc0f25221bef94e2cf Mon Sep 17 00:00:00 2001 From: Guofu Li Date: Wed, 24 Aug 2022 17:43:55 +0800 Subject: [PATCH] bug fixes --- src/DDBBase.py | 2 +- src/loader/DDBHFTLoader.py | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/DDBBase.py b/src/DDBBase.py index 368fb31..6252454 100644 --- a/src/DDBBase.py +++ b/src/DDBBase.py @@ -5,7 +5,7 @@ import dolphindb as ddb class DDBBase(object): ddb_config = { - 'host' : '192.168.1.167', + 'host' : '192.168.1.7', 'username' : 'admin', 'password' : '123456', } diff --git a/src/loader/DDBHFTLoader.py b/src/loader/DDBHFTLoader.py index 69b7087..5bcb6d4 100644 --- a/src/loader/DDBHFTLoader.py +++ b/src/loader/DDBHFTLoader.py @@ -365,8 +365,9 @@ class DDBHFTLoader(DDBLoader): elif (type_name, stock_id, 'START') in self.dump_journal_df.index: # 任务已经开始，但是没有完全结束，就需要逐个检查日期，跳过已经录入输入的交易日数据 # 同时，也不会再往日志文件中写入START记录 + partitioned_table_name = type_name + self.ddb_partition_table_suffix _journal_dt = self.ddb_sess.run(f""" - select m_nDate from tbl where code='{stock_id}' group by m_nDate map; + select m_nDate from loadTable("{self.ddb_path}", "{partitioned_table_name}") where code='{stock_id}' group by m_nDate map; """).set_index('m_nDate') else: _journal_dt = None