postgrel執行VACUUM報VACUUM cannot run inside a transaction block


 

在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) 

  

 
 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM