1、安装psycopg2

2、导入psycopg2

import psycopg2

3、连接pg数据库4、

# 通过connect方法创建数据库连接
psycopg2.connect(
    dbname="数据库名称", 
    user="用户", 
    password="密码", 
    host="ip地址", 
    port="端口号"
)

 4、访问数据库，两种方式。

        1）创建cursor以访问数据库

import pandas as pd
import psycopg2

# 通过connect方法创建数据库连接
conn = psycopg2.connect(
    dbname="数据库名称", 
    user="用户", 
    password="密码", 
    host="ip地址", 
    port="端口号"
)
# 创建cursor以访问数据库
cur = conn.cursor()
cur.execute('select * from table_name')
rows = cur.fetchall()
id,data_items = [],[]
# 遍历获取的数据
for row in rows:
	id.append(row[0])
	name.append(row[1])
df = pd.DataFrame(columns=['id','name'])
df['id'] = id
df['name'] = name
print(df)
# 提交事务
conn.commit()
# 关闭连接
conn.close()

        2）使用pandas的 read_sql（）方法。

import pandas as pd
import psycopg2

# 通过connect方法创建数据库连接
conn = psycopg2.connect(
    dbname="数据库名称", 
    user="用户", 
    password="密码", 
    host="ip地址", 
    port="端口号"
)
df = pd.read_sql("select * from table_name",con=conn)
# 提交事务
conn.commit()
# 关闭连接
conn.close()