U Jj@sTddlZddlZddlmZmZddlmZeedZ ee ddZ ddZ dS) N) create_enginetext) load_dotenv MYSQL_URIT) pool_pre_pingc Cst}t|D]\}\}}zdd|j}ddd|jD}td|d|d|d}dd |D} | || Wqt k r} z"t d |t || W5d} ~ XYqXqW5QRXdS) Nz, cSsg|]}d|qS):).0colrrB/var/www/api.dyntland.com/public_html/python_social_comments/db.py 2sz+insert_dataframe_ignore..z( INSERT IGNORE INTO z (z) VALUES (z) cSs$i|]\}}|t|rdn|qS)N)pdisna)r kvrrr 9sz+insert_dataframe_ignore..u❌ Error on row ) enginebegin enumerateiterrowsjoinindexrto_dictitemsexecute Exceptionprint) df table_nameconni_rowcolumnsZ placeholdersqueryZ clean_rowerrr insert_dataframe_ignore-s(     r&) ospandasr sqlalchemyrrdotenvrgetenvZDB_URIrr&rrrr s