数据载入

从文件路径中读取CSV文件，然后在每一次迭代中载入数据到数据库中。

        with open(file_path, "rt") as f:
            reader = csv.DictReader(f)
 
            for item in reader:

载入数据的方法可以分成2类：

• 直接插入：合约代码、交易所、K线周期、成交量、开盘价、最高价、最低价、收盘价、接口名称

• 需要处理：日期时间（根据其相应的时间格式，通过strptime()转化成时间元组）、vt_symbol(合约代码.交易所格式，如rb1909.SHFE)

注意：db_bar.replace()用于数据更新，即把旧的数据替换成新的。

                db_bar.symbol = symbol
                db_bar.exchange = exchange.value
                db_bar.datetime = datetime.strptime(
                    item[datetime_head], datetime_format
                )
                db_bar.interval = interval.value
                db_bar.volume = item[volume_head]
                db_bar.open_price = item[open_head]
                db_bar.high_price = item[high_head]
                db_bar.low_price = item[low_head]
                db_bar.close_price = item[close_head]
                db_bar.vt_symbol = vt_symbol
                db_bar.gateway_name = "DB"
 
                db_bar.replace()