sqlalchemy와 pandas로 쿼리 실행하기
Postgres 테이블에 저장된 데이터를 다루기 위해 sqlalchemy의 create_engine()와 pandas의 read_sql() 함수를 사용해 볼 거예요. 이 도구들에 익숙해지기 위해 Postgres 데이터베이스에 연결하고 쿼리를 실행하는 연습을 하겠습니다. 화이팅이에요!
이 연습은 강의의 일부입니다
NoSQL 입문
연습 안내
- 연결 URI를 업데이트하여 포트
5432를 통해disneyland데이터베이스에 연결하세요. - 이전 단계에서 만든 연결 객체를 사용해, 제공된 SQL 쿼리 결과를
pandas로 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)