다음을 사용하여 플랫폼 데이터 관리 Python 및 SQLAlchemy

Adobe Experience Platform 데이터 관리의 유연성을 높이기 위해 SQLAlchemy를 사용하는 방법에 대해 알아봅니다. SQL에 익숙하지 않은 사용자의 경우 SQLAlchemy를 사용하면 관계형 데이터베이스를 사용할 때 개발 시간을 크게 향상시킬 수 있습니다. 이 문서에서는 연결에 대한 지침과 예를 제공합니다. SQLAlchemy Query Service를 사용하고 Python을 사용하여 데이터베이스와 상호 작용하기 시작합니다.

SQLAlchemy 는 ORM(개체 관계형 매퍼) 및 Python sql 데이터베이스에 저장된 데이터를 로 전송할 수 있는 코드 라이브러리 Python 개체. 그런 다음 를 사용하여 플랫폼 데이터 레이크 내에 보관된 데이터에 대해 CRUD 작업을 수행할 수 있습니다. Python 코드. 따라서 PSQL만 사용하여 데이터를 관리할 필요가 없습니다.

시작하기

연결에 필요한 자격 증명을 획득하려면 SQLAlchemy Experience Platform을 수행하려면 Platform UI에서 쿼리 작업 영역에 액세스할 수 있어야 합니다. 현재 쿼리 작업 영역에 대한 액세스 권한이 없는 경우 조직 관리자에게 문의하십시오.

Query Service 자격 증명 credentials

자격 증명을 찾으려면 Platform UI에 로그인하고 를 선택합니다 쿼리 왼쪽 탐색 후 자격 증명. 로그인 자격 증명을 찾는 방법에 대한 전체 지침은 자격 증명 안내서.

포트 80이 쿼리 서비스 연결에 권장되는 포트이지만 포트 5432를 사용할 수도 있습니다.

QS 자격 증명에 액세스하면 Python 선택 편집자.

자격 증명 저장 위치 Python store-credentials

내 Python 편집기, 가져오기 urllib.parse.quote 라이브러리를 만들고 각 자격 증명 변수를 매개 변수로 저장합니다. 다음 urllib.parse 모듈은 URL 문자열을 구성 요소로 분할하는 표준 인터페이스를 제공합니다. quote 함수는 URL 문자열의 특수 문자를 대체하여 데이터를 URL 구성 요소로 안전하게 사용합니다. 필수 코드의 예는 아래에 나와 있습니다.

from urllib.parse import quote

host = "<YOUR_HOST>"

port = "<YOUR_PORT>"

dbname = "<YOUR_DATABASE>"

user = "<YOUR_USERNAME>"

password = quote('''
<YOUR_PASSWORD>
''')

엔진 인스턴스 만들기 [#create-engine]

변수가 만들어지면 create_engine 함수를 만들고 문자열을 만들어 SQLAlchemy에서 쿼리 서비스 자격 증명을 컴파일하고 서식을 지정합니다. 다음 create_engine 그런 다음 엔진 인스턴스를 구성하는 데 함수가 사용됩니다.

타사 클라이언트를 사용하여 플랫폼에 액세스할 때 SSL을 활성화해야 합니다. 엔진의 일부로 다음을 사용하십시오. connect_args 추가 키워드 인수를 입력합니다. SSL 모드를 다음으로 설정하는 것이 좋습니다. require. 다음을 참조하십시오. SSL 모드 설명서 을 참조하십시오.

아래 예는 Python 엔진 및 연결 문자열을 초기화하는 데 필요한 코드입니다.

from sqlalchemy import create_engine

db_string = "postgresql://{user}:{password}@{host}:{port}/{dbname}".format(
    user=user,
    password=password,
    host=host,
    port = port,
    dbname = dbname
)

engine = create_engine(db_string, connect_args={'sslmode':'require'})

이제 다음을 사용하여 플랫폼 데이터를 쿼리할 준비가 되었습니다. Python. 아래 예는 쿼리 서비스 테이블 이름의 배열을 반환합니다.

from sqlalchemy import inspect
insp = inspect(engine)
print(insp.get_table_names())