ÎļþÃû´Ó hello.py ÐÞ¸Ä |
| | |
| | | # print('\n') |
| | | after_address.append(a) |
| | | |
| | | engine = create_engine("mysql+mysqlconnector://root:1234@localhost:3306/fume?charset=utf8") |
| | | engine = create_engine("mysql+pymysql://fumeRemote:feiyu2023@114.215.109.124:3306/fume?charset=utf8") |
| | | con_read = engine.connect() |
| | | |
| | | df = pd.read_sql('SELECT b.DI_Name,a.MV_Stat_Code,a.MV_Data_Time,a.MV_Isduplication FROM fd_t_minutevalue AS a JOIN ea_t_device_info AS b ON a.MV_Stat_Code = b.DI_Code',con=con_read) |
| | |
| | | |
| | | existing_data = df.values.tolist() #DateFrameæç
§è¡è½¬ælistç±»åï¼resåæ¾çæ¯è®¾å¤ä¿¡æ¯è¡¨ä¸çæ°æ® |
| | | |
| | | # print('å·²å¤çï¼',after_address) |
| | | # print('å·²åå¨',existing_data) |
| | | |
| | | # ä¿åéå¤å¼ |
| | | duplicate_data=[] |
| | |
| | | return False,max |
| | | |
| | | |
| | | app.run(debug=True,port=8089) |
| | | app.run(debug=False,host='0.0.0.0',port=8089) |