Skip to content

Commit b99e7c3

Browse files
committed
fix(data): 修复pytdx到mysql数据导入器的参数传递问题
1 parent 64dc174 commit b99e7c3

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

hikyuu/data/pytdx_to_mysql.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -523,11 +523,11 @@ def import_data(
523523
'5MIN': 'MIN5'
524524
}
525525
nktype = ktype_dict[ktype]
526-
h5_importer = get_mysql_importer(market, nktype)
527-
if h5_importer is not None:
526+
importer = get_mysql_importer()
527+
if importer is not None:
528528
for r in failed_list:
529529
hku_warn("remove {}{} {}: {}", r[0], r[1], nktype, r[2].start_of_day())
530-
h5_importer.remove(r[0], r[1], nktype, r[2].start_of_day())
530+
importer.remove(r[0], r[1], nktype, r[2].start_of_day())
531531
hku_warn(f"已清理 {market} {failed_count} 个失败股票的最后记录,建议重新导入")
532532

533533
if failed_count >= failed_limit:

0 commit comments

Comments
 (0)