93dd7f5ae1b760772a48822cdaa9ebf9cb783ea4,QUANTAXIS/QASU/save_tdx.py,,QA_SU_save_stock_min,#Any#,99

Before Change

                    QA_fetch_get_stock_min(str(code), "2015-01-01", str(now_time())[0:19], "15min")))
        except:
            __err.append(code)
    for i_ in range(len(__stock_list)):
        //__saving_work("000001")
        QA_util_log_info("The %s of Total %s" % (i_, len(__stock_list)))
        QA_util_log_info("DOWNLOAD PROGRESS %s " % str(
            float(i_ / len(__stock_list) * 100))[0:4] + "%")
        __saving_work(__stock_list.index[i_])


def QA_SU_save_index_day(client=QA_Setting.client):
    __index_list = QA_fetch_get_stock_list("index")
    __coll = client.quantaxis.index_day
    __coll.ensure_index("code")

After Change

        except:
            __err.append(code)

    executor = ThreadPoolExecutor(max_workers=2)

    res = {executor.submit(__saving_work,__stock_list.index[i_]) for i_ in range(len(__stock_list))}
    count = 0
    for i_ in concurrent.futures.as_completed(res):
        QA_util_log_info("The %s of Total %s" % (count, len(__stock_list)))
        QA_util_log_info("DOWNLOAD PROGRESS %s " % str(
            float(count / len(__stock_list) * 100))[0:4] + "%")
        count = count + 1


def QA_SU_save_index_day(client=QA_Setting.client):
    __index_list = QA_fetch_get_stock_list("index")

Instances