U
|
èÐd¬ ã @ sX d dl T d dlZd dlmZ dd Zdd Zdd Zd
|
d Zed Z e
|
¡ Z d d Z dS )é )Ú*N)Ú create_enginec C s g }| | d ¡ | | d ¡ | | d ¡ | | d ¡ | | d ¡ | | d ¡ | | d ¡ | | d ¡ t| |S ) Né é é é é é é é )ÚappendÚprint)ÚlistÚtemp© r ú>d:\z\workplace\vscode\pyvenv\venv\src\write_to_minute_table.pyÚ refind_fd
|
s r c
|
C sN t j| ddddddddgd }td
|
t| |jd |d d d d td d S )NÚ MV_Stat_CodeÚMV_Create_TimeÚ MV_Data_TimeÚMV_Fan_ElectricityÚMV_Purifier_ElectricityÚMV_Fume_ConcentrationÚMV_Fume_Concentration2ÚMV_Isduplication)Úcolumnsu% åå
¥åæ°æ°æ®è¡¨,DateFrame为ï¼Úfd_t_minutevaluer F)ÚnameÚconÚ if_existsÚindexÚ index_labelu åéæ°æ®è¡¨åå
¥å®æ!)ÚpdÚ DataFramer Úto_sql)r r Údatar r r Úfd_write_to_SQL s
|
r& c C sD g }| D ]}| t|¡ qtd |D ] }t| q(t|| d S )Nu åéæ°æ®è½¬ååï¼)r r r r& )r r ÚstagingÚitemÚir r r Ú fd_t_minbute% s
|
r* c C s t | | d S )N)r* )Úhas_remove_duplicatesr r r r Ú write_all2 s r, úAmysql+mysqlconnector://root:1234@localhost:3306/fume?charset=utf8c C s& t d}| ¡ }t| | | ¡ d S )Nr- )r Úconnectr, Úclose)r% Úenginer r r r Úwrite: s
|
r1 ) ÚpymysqlÚpandasr" Ú
|
sqlalchemyr r r& r* r, r0 r. Úcon_readr1 r r r r Ú<module> s
|
