在python腳本里執行:
1 sql_gp1 = "VACUUM dwd_access_record_inout_temp" 2 sql_gp2 = "delete from dwd_access_record_inout_temp t where t.indate > (select now()::timestamp-interval '36 hour')" 3 conn = gputil.connect(logger,target_host,target_user,target_password,target_db) 4 #gputil是自己導入pgdb寫的模塊 5 cur = conn.cursor() 6 cur.execute(sql_gp1) 7 cur.execute(sql_gp2) 8 conn.commit() 9
報錯:
psycopg2.InternalError: VACUUM cannot run inside a transaction block
查閱資料:

報錯的原因是:Psycopg2 會開啟一個 新的 transaction 在每次調用
execute()時,而VACUUM需要在
transaction之外執行,所以我們需要打開一個
autocommit connection 去執行 vacuum。
修改后代碼:
1 conn1 = gputil.connect(logger,target_host,target_user,target_password,target_db) 2 conn2 = psycopg2.connect(database=target_db, user=target_user, password=target_password,host=target_host) 3 # conn2.set_isolation_level(0) 如果psycopg是2.4.2版本前的,只能這樣寫 4 conn2.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_AUTOCOMMIT) 5 6 cur1 = conn1.cursor() 7 cur2 = conn2.cursor() 8 9 cur2.execute(sql_gp1) 10 11 cur1.execute(sql_gp2) 12 conn1.commit() 13 14 os.system("python /application/datax2/bin/datax.py /root/test_hgm/access_record_process/dwd_inout_temp.json") 15 conn1.commit()
可能遇到的問題:
如果如下這樣寫,或者 或者自己用其他包寫的conn2報下面的錯了
1 conn2=gputil.connect(logger,target_host,target_user,target_password,target_db)

用psycopg2包(pgdb包也是調用的psycopg2)調用connect()
conn2 = psycopg2.connect(database=target_db, user=target_user,password = target_password,host=target_host)