รันคิวรีด้วย sqlalchemy และ pandas
ในการทำงานกับข้อมูลที่จัดเก็บในตาราง Postgres จะใช้ฟังก์ชัน create_engine() ของ sqlalchemy และฟังก์ชัน read_sql() ของ pandas ในแบบฝึกหัดนี้จะได้ฝึกเชื่อมต่อกับฐานข้อมูล Postgres และรันคิวรี โชคดี!
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
NoSQL เบื้องต้น
คำแนะนำการฝึกหัด
- อัปเดต connection URI เพื่อสร้างการเชื่อมต่อกับฐานข้อมูล
disneylandผ่านพอร์ต5432 - ใช้
pandasเพื่ออ่านผลลัพธ์ของ SQL query ที่กำหนดให้ลงใน DataFrame โดยใช้ connection object ที่สร้างไว้ในขั้นตอนก่อนหน้า
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
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)