使用 sqlalchemy 和 pandas 执行查询
要处理存储在 Postgres 表中的数据,您将使用 sqlalchemy 的 create_engine() 与 pandas 的 read_sql() 函数。为熟悉这些工具,您将练习连接到一个 Postgres 数据库并执行查询。祝您顺利!
本练习是课程的一部分
NoSQL 入门
练习说明
- 更新连接 URI,通过端口
5432连接到disneyland数据库。 - 使用
pandas将所给 SQL 查询的结果读入一个 DataFrame,并使用上一步创建的连接对象。
交互式实操练习
通过完成这段示例代码来试试这个练习。
import pandas as pd
import sqlalchemy
# Create a connection to the reviews database
db_engine = sqlalchemy.____("postgresql+psycopg2://repl:password@localhost:____/____")
# Execute a query against the nested_reviews table
results = pd.____("SELECT * FROM nested_reviews;", ____)
print(results)