Psycopg2는 Python을 사용하여 redshift에서 실행되는 udf create query를 허용합니까?

Question

나는, 나는이 psycopg2을 통해 UDF fucntion을 만들 실행하려고하면

그러나, 아무 일도 일어나지 않습니다 ... 등, 나는 테이블을 조회하고 다시 데이터를 얻을 수 psycopg2 파이썬을 사용하여 AWS-적색 편이에 연결할 수 있어요 오류는 반환되지 않지만 아무것도 만들어지지 않습니다. 내가 디버거를 통해 실행하고 모든 조각이있다

def _applyFunctionToDB(): 
    con=psycopg2.connect(dbname = redhsiftDatabase, host = redshiftHost, port = '5439', user = redshiftUser, password = redshiftPwd) 
    cur = con.cursor() 
    udf=_fileOpenWrite(udfFile) 
    size = os.stat(udfFile).st_size 
    udfCode=udf.read(size) 
    cur.execute(udfCode) 
    con.close() 

하지만, "실행"방법은 커서에 호출 될 때 아무 반응이 없습니다 :

여기 내 코드입니다.

여기에 무슨 일이 일어나고 있는지에 대해 조언이나 아이디어가있는 분은 조언을 구하십시오.

감사합니다! 여기 게시 후

Answer 1

발견 답 : Copying data from S3 to AWS redshift using python and psycopg2

은 내가 커밋 호출해야합니다.

따라서 실행 후 위 코드에 con.commit을 추가하십시오.