energy-data-trans/tmp_file/test_wave.py

import os
import sys
import pandas as pd
from os.path import basename, dirname

from service.trans_service import get_wave_conf

sys.path.insert(0, os.path.abspath(__file__).split("tmp_file")[0])

from etl.wind_power.wave.WaveTrans import WaveTrans

if __name__ == '__main__':
    # test = WaveTrans('SKF001', r'/home/wzl/test_data/sdk_data/sdk_data', r'/home/wzl/test_data/sdk_data')
    test = WaveTrans('SKF001', r'D:\data\sdk_data\sdk_data_less', r'/home/wzl/test_data/sdk_data')
    # D:\data\sdk_data\sdk_data_less

    # wave_conf = get_wave_conf(test.field_code)
    #
    # base_param_exec = wave_conf['base_param_exec']
    # map_dict = {}
    # if base_param_exec:
    #     base_param_exec = base_param_exec.replace('\r\n', '\n').replace('\t', '    ')
    #     print(base_param_exec)
    #     exec(base_param_exec)
    #     setattr(test, 'get_data', get_data)
    #
    #     mesure_poins = [key for key, value in wave_conf.items() if str(key).startswith('conf_') and value]
    #
    #     for point in mesure_poins:
    #         map_dict[wave_conf[point]] = point

    test.run()