from urllib import parse
import pandas as pd
from sqlalchemy import create_engine


def getConn():
    host = 'xx.xx.xx.xx'
    user = 'postgres'
    password = parse.quote_plus('xx!@7xxx')
    database = 'xxx'
    post = '5432'
    return create_engine(f"postgresql+psycopg2://{user}:{password}@{host}:{post}/{database}")


if __name__ == '__main__':
    conn = getConn()

    sql3 = '''select * from xxxx limit 200'''

    df = pd.read_sql(sql3, con=conn)

    df.to_sql(name='code_temp', schema='public', con=conn, if_exists='append', index=False)

Logo

DAMO开发者矩阵,由阿里巴巴达摩院和中国互联网协会联合发起,致力于探讨最前沿的技术趋势与应用成果,搭建高质量的交流与分享平台,推动技术创新与产业应用链接,围绕“人工智能与新型计算”构建开放共享的开发者生态。

更多推荐