빠른 시작: Python을 사용하여 Azure Database for PostgreSQL - 유연한 서버의 데이터 연결 및 쿼리
적용 대상:
Azure Database for PostgreSQL - 유연한 서버
이 빠른 시작에서는 Python을 사용하여 Azure Database for PostgreSQL 유연한 서버 인스턴스에 연결합니다. 그런 다음, SQL 문을 사용하여 Mac, Ubuntu Linux 및 Windows 플랫폼에서 데이터베이스의 데이터를 쿼리, 삽입, 업데이트 및 삭제합니다.
이 문서에서는 사용자가 Python을 사용하여 개발하는 데 익숙하지만 Azure Database for PostgreSQL 유연한 서버를 처음 사용한다고 가정합니다.
필수 조건
- 활성 구독이 있는 Azure 계정. 체험 계정을 만듭니다.
- Azure Database for PostgreSQL 유연한 서버 인스턴스. Azure Database for PostgreSQL 유연한 서버 인스턴스를 만들려면 Azure Portal을 사용하여 Azure Database for PostgreSQL - 유연한 서버 인스턴스 만들기를 참조하세요.
- Python 2.7 또는 3.6 이상
- 최신 pip 패키지 설치 관리자.
클라이언트 워크스테이션 준비
- 프라이빗 액세스(VNet 통합)를 사용하여 Azure Database for PostgreSQL 유연한 서버 인스턴스를 만든 경우 서버와 동일한 VNet 내의 리소스에서 서버에 연결해야 합니다. 가상 머신을 만들고, Azure Database for PostgreSQL 유연한 서버 인스턴스를 사용하여 만든 VNet에 이를 추가할 수 있습니다. Azure CLI를 사용하여 Azure Database for PostgreSQL - 유연한 서버 가상 네트워크 만들기 및 관리를 참조하세요.
- 퍼블릭 액세스(허용된 IP 주소)를 사용하여 Azure Database for PostgreSQL 유연한 서버 인스턴스를 만든 경우 로컬 IP 주소를 서버의 방화벽 규칙 목록에 추가할 수 있습니다. Azure CLI를 사용하여 Azure Database for PostgreSQL - 유연한 서버 방화벽 규칙 만들기 및 관리를 참조하세요.
PostgreSQL용 Python 라이브러리 설치
psycopg2 모듈은 PostgreSQL 데이터베이스를 연결 및 쿼리할 수 있도록 지원하며, Linux, macOS 또는 Windows 휠 패키지로 사용할 수 있습니다. 모든 종속 관계를 포함하는 모듈의 이진 버전을 설치합니다.
psycopg2를 설치하려면 터미널 또는 명령 프롬프트를 열고 pip install psycopg2 명령을 실행합니다.
데이터베이스 연결 정보 가져오기
Azure Database for PostgreSQL 유연한 서버 인스턴스에 연결하려면 정규화된 서버 이름 및 로그인 자격 증명이 필요합니다. Azure Portal에서 이 정보를 가져올 수 있습니다.
Azure Portal에 로그인하고 Azure Database for PostgreSQL 유연한 서버 이름을 선택합니다.
서버의 개요 페이지에서 정규화된 서버 이름 및 관리자 사용자 이름을 복사합니다. 정규화된 서버 이름은 항상 <my-server-name>.postgres.database.azure.com 형식입니다.
관리자 암호도 필요합니다. 암호를 잊어버린 경우 개요 페이지에서 다시 설정할 수 있습니다.
Python 예제를 실행하는 방법
이 문서의 각 코드 예제는 다음과 같습니다.
텍스트 편집기에서 새 파일을 만듭니다.
파일에 코드 예제를 추가합니다. 코드에서 다음과 같이 바꿉니다.
<server-name>및<admin-username>을 Azure Portal에서 복사한 값으로 바꿉니다.<admin-password>를 서버 암호로 바꿉니다.<database-name>을 Azure Database for PostgreSQL 유연한 서버 데이터베이스의 이름으로 바꿉니다. postgres라는 기본 데이터베이스는 서버를 만들 때 자동으로 생성되었습니다. SQL 명령을 사용하여 해당 데이터베이스의 이름을 바꾸거나 새 데이터베이스를 만들 수 있습니다.
프로젝트 폴더의 파일을 .py 확장명을 사용하여 저장합니다(예: postgres-insert.py). Windows의 경우 파일을 저장할 때 UTF-8 인코딩을 선택해야 합니다.
이 파일을 실행하려면 명령줄 인터페이스에서 프로젝트 폴더로 변경하고
python다음에 파일 이름을 입력합니다(예:python postgres-insert.py).
테이블 만들기 및 데이터 삽입
다음 코드 예제에서는 sycopg2.connect 함수를 사용하여 Azure Database for PostgreSQL 유연한 서버 데이터베이스에 연결하고 SQL INSERT 문을 사용하여 데이터를 로드합니다. cursor.execute 함수는 데이터베이스에 대해 SQL 쿼리를 실행합니다.
import psycopg2
# Update connection string information
host = "<server-name>"
dbname = "<database-name>"
user = "<admin-username>"
password = "<admin-password>"
sslmode = "require"
# Construct connection string
conn_string = "host={0} user={1} dbname={2} password={3} sslmode={4}".format(host, user, dbname, password, sslmode)
conn = psycopg2.connect(conn_string)
print("Connection established")
cursor = conn.cursor()
# Drop previous table of same name if one exists
cursor.execute("DROP TABLE IF EXISTS inventory;")
print("Finished dropping table (if existed)")
# Create a table
cursor.execute("CREATE TABLE inventory (id serial PRIMARY KEY, name VARCHAR(50), quantity INTEGER);")
print("Finished creating table")
# Insert some data into the table
cursor.execute("INSERT INTO inventory (name, quantity) VALUES (%s, %s);", ("banana", 150))
cursor.execute("INSERT INTO inventory (name, quantity) VALUES (%s, %s);", ("orange", 154))
cursor.execute("INSERT INTO inventory (name, quantity) VALUES (%s, %s);", ("apple", 100))
print("Inserted 3 rows of data")
# Clean up
conn.commit()
cursor.close()
conn.close()
코드가 성공적으로 실행되면 다음과 같은 출력이 생성됩니다.
데이터 읽기
다음 코드 예제에서는 Azure Database for PostgreSQL 유연한 서버 데이터베이스에 연결하고 cursor.execute와 SQL SELECT 문을 사용하여 데이터를 읽습니다. 이 함수는 쿼리를 허용하며, cursor.fetchall()을 사용하여 반복할 결과 집합을 반환합니다.
import psycopg2
# Update connection string information
host = "<server-name>"
dbname = "<database-name>"
user = "<admin-username>"
password = "<admin-password>"
sslmode = "require"
# Construct connection string
conn_string = "host={0} user={1} dbname={2} password={3} sslmode={4}".format(host, user, dbname, password, sslmode)
conn = psycopg2.connect(conn_string)
print("Connection established")
cursor = conn.cursor()
# Fetch all rows from table
cursor.execute("SELECT * FROM inventory;")
rows = cursor.fetchall()
# Print all rows
for row in rows:
print("Data row = (%s, %s, %s)" %(str(row[0]), str(row[1]), str(row[2])))
# Cleanup
conn.commit()
cursor.close()
conn.close()
데이터 업데이트
다음 코드 예제에서는 Azure Database for PostgreSQL 유연한 서버 데이터베이스에 연결하고 cursor.execute와 SQL UPDATE 문을 사용하여 데이터를 업데이트합니다.
import psycopg2
# Update connection string information
host = "<server-name>"
dbname = "<database-name>"
user = "<admin-username>"
password = "<admin-password>"
sslmode = "require"
# Construct connection string
conn_string = "host={0} user={1} dbname={2} password={3} sslmode={4}".format(host, user, dbname, password, sslmode)
conn = psycopg2.connect(conn_string)
print("Connection established")
cursor = conn.cursor()
# Update a data row in the table
cursor.execute("UPDATE inventory SET quantity = %s WHERE name = %s;", (200, "banana"))
print("Updated 1 row of data")
# Cleanup
conn.commit()
cursor.close()
conn.close()
데이터 삭제
다음 코드 예제에서는 Azure Database for PostgreSQL 유연한 서버 데이터베이스에 연결하고 cursor.execute와 SQL DELETE 문을 사용하여 이전에 삽입한 인벤토리 항목을 삭제합니다.
import psycopg2
# Update connection string information
host = "<server-name>"
dbname = "<database-name>"
user = "<admin-username>"
password = "<admin-password>"
sslmode = "require"
# Construct connection string
conn_string = "host={0} user={1} dbname={2} password={3} sslmode={4}".format(host, user, dbname, password, sslmode)
conn = psycopg2.connect(conn_string)
print("Connection established")
cursor = conn.cursor()
# Delete data row from table
cursor.execute("DELETE FROM inventory WHERE name = %s;", ("orange",))
print("Deleted 1 row of data")
# Cleanup
conn.commit()
cursor.close()
conn.close()