原油八大维度发版前测试
This commit is contained in:
jingboyitiji
parent
a3b1beeb0f
commit
fc979d26ff
@ -364,9 +364,9 @@ table_name = 'v_tbl_crude_oil_warning'
|
||||
|
||||
|
||||
# 开关
|
||||
is_train = False # 是否训练
|
||||
is_debug = True # 是否调试
|
||||
is_eta = False # 是否使用eta接口
|
||||
is_train = True # 是否训练
|
||||
is_debug = False # 是否调试
|
||||
is_eta = True # 是否使用eta接口
|
||||
is_market = True # 是否通过市场信息平台获取特征 ,在is_eta 为true 的情况下生效
|
||||
is_timefurture = True # 是否使用时间特征
|
||||
is_fivemodels = False # 是否使用之前保存的最佳的5个模型
|
||||
|
||||
@ -382,9 +382,9 @@ table_name = 'v_tbl_crude_oil_warning'
|
||||
|
||||
|
||||
# 开关
|
||||
is_train = False # 是否训练
|
||||
is_debug = True # 是否调试
|
||||
is_eta = False # 是否使用eta接口
|
||||
is_train = True # 是否训练
|
||||
is_debug = False # 是否调试
|
||||
is_eta = True # 是否使用eta接口
|
||||
is_market = True # 是否通过市场信息平台获取特征 ,在is_eta 为true 的情况下生效
|
||||
is_timefurture = True # 是否使用时间特征
|
||||
is_fivemodels = False # 是否使用之前保存的最佳的5个模型
|
||||
|
||||
@ -326,7 +326,7 @@ table_name = 'v_tbl_crude_oil_warning'
|
||||
|
||||
# 开关
|
||||
is_train = True # 是否训练
|
||||
is_debug = True # 是否调试
|
||||
is_debug = False # 是否调试
|
||||
is_eta = True # 是否使用eta接口
|
||||
is_market = True # 是否通过市场信息平台获取特征 ,在is_eta 为true 的情况下生效
|
||||
is_timefurture = True # 是否使用时间特征
|
||||
|
||||
@ -20,13 +20,97 @@ edbdeleteurl = 'http://10.189.2.78:8108/v1/edb/business/edb/del'
|
||||
edbbusinessurl = 'http://10.189.2.78:8108/v1/edb/business/data/del'
|
||||
|
||||
edbcodenamedict = {
|
||||
'C2403283369': '预赔阳极加工利润（高端）',
|
||||
'C2403285560': '预培阳极加工利润（低端）',
|
||||
'C2403288616': '低硫石油焦煅烧利润',
|
||||
'S6949656': '平均价：氧化铝：一级：全国',
|
||||
'S5807052': '氧化铝：一级：贵阳',
|
||||
'S5443355': '市场价：煤沥青：河北地区',
|
||||
'S5443357': '市场价：煤沥青：山西地区',
|
||||
'C2403287411': '华北高硫焦与等热值动力煤价格对比',
|
||||
'C2403282801': '华东高硫焦与等热值动力煤价格对比',
|
||||
'ID00150321': '石油焦：2 # A：市场低端价：山东（日）',
|
||||
'ID00150329': '石油焦：2 # A：市场主流价：山东（日）',
|
||||
'ID00150325': '石油焦：2 # A：市场高端价：山东（日）',
|
||||
'ID00150333': '石油焦：2 # B：市场低端价：山东（日）',
|
||||
'ID00150357': '石油焦：2 # B：市场主流价：山东（日）',
|
||||
'ID00150345': '石油焦：2 # B：市场高端价：山东（日）',
|
||||
'ID01101276': '高硫焦：4B：出厂价：山东：青岛炼化（日）',
|
||||
'ID00150417': '石油焦：高硫焦：市场低端价：华北地区（日）',
|
||||
'ID00150425': '石油焦：高硫焦：市场低端价：华南地区（日）',
|
||||
'ID00150437': '石油焦：高硫焦：市场高端价：华北地区（日）',
|
||||
'ID00150441': '石油焦：高硫焦：市场高端价：华东地区（日）',
|
||||
'ID00150445': '石油焦：高硫焦：市场高端价：华南地区（日）',
|
||||
'ID00150449': '石油焦：高硫焦：市场高端价：西北地区（日）',
|
||||
'ID00150453': '石油焦：高硫焦：市场高端价：西南地区（日）',
|
||||
'ID01300358': '石油焦：3 # C：市场低端价：山东（日）',
|
||||
'ID01300357': '石油焦：3 # C：市场高端价：山东（日）',
|
||||
'ID00150377': '石油焦：3 # ：市场主流价：华中地区（日）',
|
||||
'ID01387678': '煅烧焦：中硫：3 % S：市场价：华中地区（日）',
|
||||
'ID01387656': '煅烧焦：中硫：3 % S：市场价：山东（日）',
|
||||
'ID00150381': '石油焦：3 # A：市场低端价：山东（日）',
|
||||
'ID00150397': '石油焦：3 # B：市场低端价：山东（日）',
|
||||
'ID00150405': '石油焦：3 # B：市场高端价：山东（日）',
|
||||
'ID00150429': '石油焦：高硫焦：市场低端价：西北地区（日）',
|
||||
'ID00150433': '石油焦：高硫焦：市场低端价：西南地区（日）',
|
||||
'ID00150457': '石油焦：高硫焦：市场主流价：华北地区（日）',
|
||||
'ID00150461': '石油焦：高硫焦：市场主流价：华东地区（日）',
|
||||
'ID00150465': '石油焦：高硫焦：市场主流价：华南地区（日）',
|
||||
'ID00150469': '石油焦：高硫焦：市场主流价：西北地区（日）',
|
||||
'ID00150473': '石油焦：高硫焦：市场主流价：西南地区（日）',
|
||||
'ID00150421': '石油焦：高硫焦：市场低端价：华东地区（日）',
|
||||
'B3e90b34e4b9e7a6ea3': '石油焦市场均价(元/吨)',
|
||||
'B8a0ab5357569c385a9': '石油焦海绵焦市场均价(元/吨)',
|
||||
'B8a920b59fe7effd116': '石油焦4 # -5#市场均价(元/吨)',
|
||||
'B81e66c7dc542809035': '石油焦海绵焦华东高硫焦（低端）(元/吨)（百川）',
|
||||
'B6fc631d20e277ce496': '石油焦海绵焦华东高硫焦（高端）(元/吨)（百川）',
|
||||
'Be9ed3ebd44ad291a3c': '石油焦海绵焦华南高硫焦（低端）(元/吨)（百川）',
|
||||
'B347350473783e640dc': '石油焦海绵焦华南高硫焦（高端）(元/吨)（百川）',
|
||||
'B7acab268ac4a419f77': '煅烧焦华北中硫(低端S < 3.0，普货)(元/吨)',
|
||||
'Beecfb2678481997f68': '煅烧焦山东中硫(高端S < 3.0，普货)(元/吨)',
|
||||
'B4bc4d186dc0f7d6d96': '煅烧焦华中中硫(高端S < 3.0，普货)(元/吨)',
|
||||
'B46cc7d0a90155b5bfd': '煅烧焦山东高硫(高端S < 3.5，普货)(元/吨)',
|
||||
'B4501068048575cd6f1': '煅烧焦西北高硫(S < 4.0，普货)(元/吨)',
|
||||
'Bfccb234f4c4e047314': '煅烧焦中硫普货市场均价(硫 < 3.0 %)(元/吨)',
|
||||
'B1133e458cc493d7728': '煅烧焦高硫普货市场均价(元/吨)（百川）',
|
||||
'B185a597decfc71915a': '预焙阳极山东低端(元/吨)（百川）',
|
||||
'B16b98ff5f959dfdcad': '负极材料市场参考价(元/吨)（百川）',
|
||||
'B7ce1371e09479bee56': '人造石墨负极材料中端(元/吨)',
|
||||
'Bab0904b23e968a3068': '天然石墨负极材料中端(元/吨)',
|
||||
'B180e67aaa174414553': '中间相碳微球负极材料高端(元/吨)',
|
||||
'B41c03de42ea84d5c2f': '中间相碳微球负极材料中端(元/吨)',
|
||||
'B5c3b60680b7bbd92af': '负极材料石墨化国内低端价(元/吨)',
|
||||
'B1bcde6130de031bd42': '山西 改质沥青(元/吨)',
|
||||
'Bb9f4a1f6dd32b4ad8a': '山东 改质沥青(元/吨)',
|
||||
'C2411261557491549': '石油焦市场均价(元/吨)/4DMA',
|
||||
'C2411271143174617': '石油焦市场均价(元/吨)/9DMA',
|
||||
'RE00010074': '煅烧焦：中硫焦：生产毛利：山东（周）',
|
||||
'B9d1acaf80383683da3': '石油焦总产量（周）(吨)',
|
||||
'Bdaa719a38936c8dd76': '石油焦开工率（周）(% )',
|
||||
'B9459d549a332b200e7': '石油焦行业总库存（周）(吨)',
|
||||
'Bce6e098b9518370cff': '石油焦工厂库存（周）(吨)',
|
||||
'B577ce2809772779710': '石油焦市场库存（周）(吨)',
|
||||
'B5d8c564c62f3e6b77f': '石油焦成本（周）(吨)',
|
||||
'B43baa98bcaa06c11a5': '石油焦利润（周）(吨)',
|
||||
'Bdd0c1361d94081211c': '煅烧石油焦总产量（周）(吨)',
|
||||
'B65315111fa28951b1e': '煅烧石油焦开工率（周）(% )',
|
||||
'B2aff5f2632a20027d0': '煅烧石油焦行业总库存（周）(吨)',
|
||||
'B29fbd31128cd71b212': '煅烧石油焦工厂库存（周）(吨)',
|
||||
'B7a88313a89d1261c53': '煅烧石油焦成本（周）(吨)',
|
||||
'Bd4fa36b4decec0aafa': '煅烧石油焦利润（周）(吨)',
|
||||
'B9bd80eac7df81ffbd4': '预焙阳极总产量（周）(吨)',
|
||||
'B27074786605f4660d2': '预焙阳极开工率（周）(% )',
|
||||
'Bdc2a5985ecb56b6a0c': '预焙阳极行业总库存（周）(吨)',
|
||||
'Bce8511f899e487e5b6': '预焙阳极工厂库存（周）(吨)',
|
||||
'B13ec89105bd866a2bd': '预焙阳极成本（周）(吨)',
|
||||
'B66c3abcfa15a2e611c': '预焙阳极利润（周）(吨)',
|
||||
'Ba3bcf63e6e846cd3f8': '负极材料总产量（周）(吨)',
|
||||
'B10b8f4c702b72f4ee4': '负极材料开工率（周）(% )',
|
||||
'Bc25e82dd595c5f92fc': '负极材料行业总库存（周）(吨)',
|
||||
'B0a14d1936a5e072f25': '负极材料工厂库存（周）(吨)',
|
||||
'Ba9d192464b78194a48': '负极材料成本（周）(吨)',
|
||||
'B15d62d9f48ccfa5984': '负极材料利润（周）(吨)',
|
||||
'B7478e77ca116386afd': '针状焦总产量（周）(吨)',
|
||||
'Bbe316d65258a4d47f4': '针状焦行业总库存（周）(吨)',
|
||||
'Bf036a360a5eecb591d': '针状焦工厂库存（周）(吨)',
|
||||
'Bc43a790c62aa57fc9d': '针状焦成本（周）(吨)',
|
||||
'B23ebedbb88ff412952': '针状焦利润（周）(吨)',
|
||||
'C2403286685': '黄骅港动力煤等热值',
|
||||
'C2403285171': '黄骅等热值动力煤',
|
||||
'C2403287884': '中硫石油焦煅烧利润',
|
||||
'W000294': '国内主要港口石油焦出货量（隆重）',
|
||||
'W000293': '日照港库存（隆重）',
|
||||
'W000292': '港口总库存（隆重）',
|
||||
@ -35,104 +119,9 @@ edbcodenamedict = {
|
||||
'W000281': '中国石油焦产量（隆重）',
|
||||
'W000280': '主营石油焦开工负荷率（隆重）',
|
||||
'W000279': '地炼石油焦开工负荷率（隆重）',
|
||||
'ID00150273': '石油焦：1 # ：市场低端价：东北地区（日）',
|
||||
'ID00150281': '石油焦：1 # ：市场主流价：东北地区（日）',
|
||||
'ID00150277': '石油焦：1 # ：市场高端价：东北地区（日）',
|
||||
'ID00150289': '石油焦：2 # ：市场低端价：华东地区（日）',
|
||||
'ID00150285': '石油焦：2 # ：市场低端价：西北地区（日）',
|
||||
'ID00150313': '石油焦：2 # ：市场主流价：华东地区（日）',
|
||||
'ID00150309': '石油焦：2 # ：市场主流价：西北地区（日）',
|
||||
'ID00150301': '石油焦：2 # ：市场高端价：华东地区（日）',
|
||||
'ID00150297': '石油焦：2 # ：市场高端价：西北地区（日）',
|
||||
'ID00150321': '石油焦：2 # A：市场低端价：山东（日）',
|
||||
'ID00150329': '石油焦：2 # A：市场主流价：山东（日）',
|
||||
'ID00150325': '石油焦：2 # A：市场高端价：山东（日）',
|
||||
'ID00150337': '石油焦：2 # B：市场低端价：华南地区（日）',
|
||||
'ID00150341': '石油焦：2 # B：市场低端价：华中地区（日）',
|
||||
'ID00150361': '石油焦：2 # B：市场主流价：华南地区（日）',
|
||||
'ID00150365': '石油焦：2 # B：市场主流价：华中地区（日）',
|
||||
'ID00150349': '石油焦：2 # B：市场高端价：华南地区（日）',
|
||||
'ID00150353': '石油焦：2 # B：市场高端价：华中地区（日）',
|
||||
'ID00150333': '石油焦：2 # B：市场低端价：山东（日）',
|
||||
'ID00150357': '石油焦：2 # B：市场主流价：山东（日）',
|
||||
'ID00150345': '石油焦：2 # B：市场高端价：山东（日）',
|
||||
'ID00150369': '石油焦：3 # ：市场低端价：华中地区（日）',
|
||||
'ID00150373': '石油焦：3 # ：市场高端价：华中地区（日）',
|
||||
'ID00150385': '石油焦：3 # A：市场高端价：山东（日）',
|
||||
'ID00150393': '石油焦：3 # B：市场低端价：华东地区（日）',
|
||||
'ID00150409': '石油焦：3 # B：市场主流价：华东地区（日）',
|
||||
'ID00150401': '石油焦：3 # B：市场高端价：华东地区（日）',
|
||||
'ID00146589': '海绵焦：4 # ：出厂价：华中地区：洛阳石化（日）',
|
||||
'ID01242846': '石油焦：4 # B：挂牌价：华北地区：中石化燕山（日）',
|
||||
'ID01300358': '石油焦：3 # C：市场低端价：山东（日）',
|
||||
'ID01300357': '石油焦：3 # C：市场高端价：山东（日）',
|
||||
'ID00150377': '石油焦：3 # ：市场主流价：华中地区（日）',
|
||||
'ID01387643': '煅烧焦：低硫：0.5 % S：市场价：东北地区（日）',
|
||||
'ID01387646': '煅烧焦：低硫：3.5 % S：市场价：东北地区（日）',
|
||||
'ID01387660': '煅烧焦：中硫：3 % S，400V：市场价：山东（日）',
|
||||
'ID00150381': '石油焦：3 # A：市场低端价：山东（日）',
|
||||
'ID00150397': '石油焦：3 # B：市场低端价：山东（日）',
|
||||
'ID00150405': '石油焦：3 # B：市场高端价：山东（日）',
|
||||
'ID00146545': '海绵焦：3B：出厂价：山东：山东东明（日）',
|
||||
'B3e90b34e4b9e7a6ea3': '石油焦市场均价(元/吨)',
|
||||
'B6b5c53b270a3af12ac': '石油焦1 # 市场均价(元/吨)',
|
||||
'B10721189a11c209a20': '石油焦2 # 市场均价(元/吨)',
|
||||
'B6accfa9d2bf4735a50': '石油焦3 # 市场均价(元/吨)',
|
||||
'B8a0ab5357569c385a9': '石油焦海绵焦市场均价(元/吨)',
|
||||
'B19dcf45e22fbfd3e43': '石油焦海绵焦东北1 # A焦（低端）(元/吨)（百川）',
|
||||
'B5832a62d1e0fba50b6': '石油焦海绵焦东北1 # A焦（高端）(元/吨)（百川）',
|
||||
'B1de4fba026d4609cc7': '石油焦海绵焦东北1 # B焦（低端）(元/吨)（百川）',
|
||||
'B38f89180736172490d': '石油焦海绵焦东北1 # B焦（高端）(元/吨)（百川）',
|
||||
'B4f847871674c3d77f2': '石油焦海绵焦山东地炼1 # -3#焦（低端）(元/吨)',
|
||||
'B1aefb8a64a5200adbd': '石油焦海绵焦山东地炼1 # -3#焦（高端）(元/吨)',
|
||||
'B1df7d0afbfedfb628a': '煅烧焦东北低硫(高端S < 0.5)(元/吨)',
|
||||
'B5f8f9859635876da28': '煅烧焦东北低硫(低端S < 0.5)(元/吨)',
|
||||
'B2342a8c5a39fa00348': '煅烧焦华北中硫(高端S < 3.0，钒 < 400)(元/吨)',
|
||||
'B051f27900397c6a35f': '煅烧焦山东中硫(高端S < 3.0，钒 < 400)(元/吨)',
|
||||
'Be2a8050a48e86cae1f': '煅烧焦华东中硫(高端S < 3.0，钒 < 400)(元/吨)',
|
||||
'B4a1811938f85065f6a': '煅烧焦华中中硫(高端S < 3.0，钒 < 400)(元/吨)',
|
||||
'Bc197d4834ef7fb98ec': '煅烧焦华东高硫(高端S < 3.5，钒 < 400)(元/吨)',
|
||||
'B62be5dbdb8c6454530': '煅烧焦低硫参考价格(元/吨)（百川）',
|
||||
'Bdd813140bffc4edfa6': '煅烧焦中硫微量市场均价(元/吨)（百川）',
|
||||
'B185a597decfc71915a': '预焙阳极山东低端(元/吨)（百川）',
|
||||
'B1bcde6130de031bd42': '山西 改质沥青(元/吨)',
|
||||
'Bb9f4a1f6dd32b4ad8a': '山东 改质沥青(元/吨)',
|
||||
'C2411261557491549': '石油焦市场均价(元/吨)/4DMA',
|
||||
'C2411271143174617': '石油焦市场均价(元/吨)/9DMA',
|
||||
'ID01387649': '煅烧焦：中硫：3 % S，350V：市场价：华东地区（日）',
|
||||
'ID01387655': '煅烧焦：中硫：3 % S，350V：市场价：山东（日）',
|
||||
'RE00010076': '煅烧焦：低硫：生产毛利：东北地区（周）',
|
||||
'B9d1acaf80383683da3': '石油焦总产量（周）(吨)',
|
||||
'Bdaa719a38936c8dd76': '石油焦开工率（周）( % )',
|
||||
'B9459d549a332b200e7': '石油焦行业总库存（周）(吨)',
|
||||
'Bce6e098b9518370cff': '石油焦工厂库存（周）(吨)',
|
||||
'B577ce2809772779710': '石油焦市场库存（周）(吨)',
|
||||
'B5d8c564c62f3e6b77f': '石油焦成本（周）(吨)',
|
||||
'B43baa98bcaa06c11a5': '石油焦利润（周）(吨)',
|
||||
'Bdd0c1361d94081211c': '煅烧石油焦总产量（周）(吨)',
|
||||
'B65315111fa28951b1e': '煅烧石油焦开工率（周）( % )',
|
||||
'B2aff5f2632a20027d0': '煅烧石油焦行业总库存（周）(吨)',
|
||||
'B29fbd31128cd71b212': '煅烧石油焦工厂库存（周）(吨)',
|
||||
'B7a88313a89d1261c53': '煅烧石油焦成本（周）(吨)',
|
||||
'Bd4fa36b4decec0aafa': '煅烧石油焦利润（周）(吨)',
|
||||
'B9bd80eac7df81ffbd4': '预焙阳极总产量（周）(吨)',
|
||||
'B27074786605f4660d2': '预焙阳极开工率（周）( % )',
|
||||
'Bdc2a5985ecb56b6a0c': '预焙阳极行业总库存（周）(吨)',
|
||||
'Bce8511f899e487e5b6': '预焙阳极工厂库存（周）(吨)',
|
||||
'B13ec89105bd866a2bd': '预焙阳极成本（周）(吨)',
|
||||
'B66c3abcfa15a2e611c': '预焙阳极利润（周）(吨)',
|
||||
'Bf7efe3200f9abc0453': '电解铝开工率（周）( % )',
|
||||
'Be193166f347267b1a7': '电解铝行业总库存（周）(吨)',
|
||||
'Baa744fc97769353175': '电解铝工厂库存（周）(吨)',
|
||||
'Bf9654603913cfc5282': '电解铝市场库存（周）(吨)',
|
||||
'Bef1535c96da0d70fbc': '电解铝利润（周）(吨)',
|
||||
'B7d1d0b24316d49cbdc': '煤沥青总产量（周）(吨)',
|
||||
'B4303fb002ea1c214da': '煤沥青开工率（周）( % )',
|
||||
'Be9a470c97e9efe660c': '煤沥青行业总库存（周）(吨)',
|
||||
'B50d4d87f6b78bca587': '煤沥青工厂库存（周）(吨)',
|
||||
'B46cc7d0a90155b5bfd': '煅烧焦山东高硫(高端S < 3.5，普货)(元/吨)'
|
||||
}
|
||||
|
||||
|
||||
edbcodelist = edbcodenamedict.keys()
|
||||
# 临时写死用指定的列,与上面的edbcode对应，后面更改
|
||||
edbnamelist = ['ds', 'y']+[edbcodenamedict[edbcodename]
|
||||
|
||||
@ -1,7 +1,7 @@
|
||||
# 读取配置
|
||||
|
||||
from lib.dataread import *
|
||||
from config_shiyoujiao_lvyong_zhoudu import *
|
||||
from config_shiyoujiao_puhuo_zhoudu import *
|
||||
from lib.tools import SendMail, exception_logger
|
||||
from models.nerulforcastmodels import ex_Model, model_losss, shiyoujiao_lvyong_export_pdf
|
||||
import datetime
|
||||
|
||||
@ -16,8 +16,9 @@ def run_predictions(target_date):
|
||||
|
||||
# 依次执行每个脚本
|
||||
for script in scripts:
|
||||
# command = [r"C:\Users\Hello\.conda\envs\predict\python", script]
|
||||
command = [r"C:\Users\EDY\.conda\envs\predict\python", script]
|
||||
# command = [r"C:\Users\EDY\.conda\envs\predict\python", script]
|
||||
command = [r"C:/Users/Hello/.conda/envs/jaigeyuce/python.exe", script] #yitijipc
|
||||
|
||||
subprocess.run(command, check=True)
|
||||
|
||||
|
||||
@ -27,9 +28,9 @@ def is_weekday(date):
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
start_date = datetime.date(2025, 2, 1)
|
||||
# start_date = datetime.date(2025, 2, 1)
|
||||
# 开始时间取当前时间
|
||||
# start_date = datetime.date.today()
|
||||
start_date = datetime.date.today()
|
||||
end_date = datetime.date(2025, 3, 31)
|
||||
|
||||
current_date = start_date
|
||||
@ -47,7 +48,10 @@ if __name__ == "__main__":
|
||||
|
||||
# current_date += datetime.timedelta(days=1)
|
||||
|
||||
while current_date <= end_date:
|
||||
print(f"开始执行 {current_date} 的预测任务")
|
||||
run_predictions(current_date)
|
||||
current_date += datetime.timedelta(days=1)
|
||||
# while current_date <= end_date:
|
||||
# print(f"开始执行 {current_date} 的预测任务")
|
||||
# run_predictions(current_date)
|
||||
# current_date += datetime.timedelta(days=1)
|
||||
|
||||
print(f"开始执行 {current_date} 的预测任务")
|
||||
run_predictions(current_date)
|
||||
@ -1,22 +0,0 @@
|
||||
# 定时执行cmd命令
|
||||
|
||||
import time
|
||||
import os
|
||||
while True:
|
||||
try:
|
||||
print(time.strftime('%H:%M'))
|
||||
# 判断是不是工作日且 是17：00 7：00 才执行
|
||||
if time.strftime('%A') not in ['Saturday', 'Sunday'] and time.strftime('%H:%M') in ['07:50']:
|
||||
# 要执行的命令
|
||||
command = r"d:\yuanyouyuce\envs\predict\python main_yuanyou.py"
|
||||
|
||||
# 调用系统命令
|
||||
os.system(command)
|
||||
time.sleep(60)
|
||||
except:
|
||||
time.sleep(3600)
|
||||
# 要执行的命令
|
||||
command = r"d:\yuanyouyuce\envs\predict\python main_yuanyou.py"
|
||||
|
||||
# 调用系统命令
|
||||
os.system(command)
|
||||
52
石油焦铝用八大维度预测任务.py
Normal file
52
石油焦铝用八大维度预测任务.py
Normal file
@ -0,0 +1,52 @@
|
||||
# 这是原油日度，周度，月度的预测，脚本
|
||||
# 遍历时间，跳过周六日，每日7点开始预测
|
||||
|
||||
import datetime
|
||||
import subprocess
|
||||
import time
|
||||
|
||||
|
||||
def run_predictions(target_date):
|
||||
"""执行三个预测脚本"""
|
||||
scripts = [
|
||||
"main_shiyoujiao_lvyong.py",
|
||||
"main_shiyoujiao_lvyong_zhoudu.py",
|
||||
"main_shiyoujiao_lvyong_yuedu.py"
|
||||
]
|
||||
|
||||
# 依次执行每个脚本
|
||||
for script in scripts:
|
||||
# command = [r"C:\Users\Hello\.conda\envs\predict\python", script] # liuruipc
|
||||
# command = [r"C:/Users/EDY/.conda/envs/priceforecast/python.exe", script] #168pc
|
||||
command = [r"C:/Users/Hello/.conda/envs/jaigeyuce/python.exe", script] #yitijipc
|
||||
subprocess.run(command, check=True)
|
||||
|
||||
|
||||
def is_weekday(date):
|
||||
"""判断是否为工作日（周一到周五）"""
|
||||
return date.weekday() < 5 # 0-4 为周一到周五
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
# start_date = datetime.date(2025, 3, 13)
|
||||
# 开始时间取当前时间
|
||||
start_date = datetime.date.today()
|
||||
# end_date = datetime.date(2100, 12, 31)
|
||||
|
||||
current_date = start_date
|
||||
# while current_date <= end_date:
|
||||
# if is_weekday(current_date):
|
||||
# # 等待到目标日期的7点
|
||||
# target_time = datetime.datetime.combine(
|
||||
# current_date, datetime.time(13, 15))
|
||||
# while datetime.datetime.now() < target_time:
|
||||
# time.sleep(60) # 每分钟检查一次
|
||||
# print(f"等待到 {target_time} 开始执行任务")
|
||||
|
||||
# print(f"开始执行 {current_date} 的预测任务")
|
||||
# run_predictions(current_date)
|
||||
|
||||
# current_date += datetime.timedelta(days=1)
|
||||
|
||||
print(f"开始执行 {current_date} 的预测任务")
|
||||
run_predictions(current_date)
|
||||
@ -18,7 +18,7 @@ def run_predictions(target_date):
|
||||
for script in scripts:
|
||||
# command = [r"C:\Users\Hello\.conda\envs\predict\python", script] # liuruipc
|
||||
# command = [r"C:/Users/EDY/.conda/envs/priceforecast/python.exe", script] #168pc
|
||||
command = [r"C:/Users/Hello/.conda/envs/predict/python.exe", script] #yitijipc
|
||||
command = [r"C:/Users/Hello/.conda/envs/jaigeyuce/python.exe", script] #yitijipc
|
||||
subprocess.run(command, check=True)
|
||||
|
||||
|
||||
|
||||
@ -1,22 +0,0 @@
|
||||
# 定时执行cmd命令
|
||||
|
||||
import time
|
||||
import os
|
||||
while True:
|
||||
try:
|
||||
print(time.strftime('%H:%M'))
|
||||
# 判断是不是工作日且 是17：00 7：00 才执行
|
||||
if time.strftime('%A') not in ['Saturday', 'Sunday'] and time.strftime('%H:%M') in ['16:10']:
|
||||
# 要执行的命令
|
||||
command = r"d:\yuanyouyuce\envs\predict\python main_yuanyou.py"
|
||||
|
||||
# 调用系统命令
|
||||
os.system(command)
|
||||
time.sleep(60)
|
||||
except:
|
||||
time.sleep(3600)
|
||||
# 要执行的命令
|
||||
command = r"d:\yuanyouyuce\envs\predict\python main_juxiting.py"
|
||||
|
||||
# 调用系统命令
|
||||
os.system(command)
|
||||
Loading…
Reference in New Issue
Block a user