쿼리 서비스에서 중첩 데이터 구조 작업

마지막 업데이트: 2025년 4월 4일

작성 대상:

  • 사용자
  • 개발자

Adobe Experience Platform 쿼리 서비스는 중첩 데이터 필드의 사용을 지원합니다. 엔터프라이즈 데이터 구조가 복잡하면 이 데이터의 변환이나 처리가 복잡해질 수 있습니다. 이 문서에서는 중첩된 데이터 구조를 비롯한 복잡한 데이터 유형을 사용하여 데이터 세트를 만들거나, 처리하거나, 변형하는 방법에 대한 예를 제공합니다.

쿼리 서비스는 Experience Platform에서 관리하는 모든 데이터 세트에서 SQL 쿼리를 실행할 수 있는 PostgreSQL 인터페이스를 제공합니다. Experience Platform에서는 구조체, 배열, 맵 및 깊게 중첩된 구조체, 배열 및 맵과 같은 테이블 열에서 기본 데이터 형식 또는 복잡한 데이터 형식을 사용할 수 있습니다. 또한 데이터 세트에는 열 데이터 유형이 중첩된 구조의 배열만큼 복잡할 수 있는 중첩된 구조나 키-값 쌍의 값이 여러 수준의 중첩을 갖는 구조일 수 있는 맵 맵이 포함될 수 있습니다.

시작하기

이 자습서에서는 서드파티 PSQL 클라이언트 또는 쿼리 편집기 도구를 사용하여 Experience Platform UI(사용자 인터페이스) 내에서 쿼리를 작성, 유효성 검사 및 실행해야 합니다. UI를 통해 쿼리를 실행하는 방법에 대한 자세한 내용은 쿼리 편집기 UI 안내서를 참조하십시오. 타사 데스크톱 클라이언트가 쿼리 서비스에 연결할 수 있는 자세한 목록을 보려면 클라이언트 연결 개요를 참조하십시오.

INSERT INTO 및 CTAS 구문도 잘 알고 있어야 합니다. 사용에 대한 특정 정보는 SQL 구문 참조 설명서의 INSERT INTO 및 CTAS 섹션에서 찾을 수 있습니다.

데이터 세트 만들기

쿼리 서비스는 SELECT 문의 출력을 기반으로 또는 이 경우처럼 Adobe Experience Platform의 기존 XDM 스키마에 대한 참조를 사용하여 테이블을 만드는 Create Table As Select(CTAS) 기능을 제공합니다. 이 예제에 대해 만들어진 Final_subscription에 대한 XDM 스키마는 아래에 표시됩니다.

final_subscription 스키마의 다이어그램입니다.

다음 예제에서는 final_subscription_test2 데이터 집합을 만드는 데 사용되는 SQL을 보여 줍니다. Final_subscription 스키마를 사용하여 final_subscription_test2을(를) 만듭니다. 일부 행을 채우기 위해 SELECT 절을 사용하여 소스에서 데이터를 추출합니다.

CREATE TABLE final_subscription_test2 with(schema='Final_subscription') AS (
        SELECT struct(userid, collect_set(subscription) AS subscription) AS _lumaservices3 FROM(
            SELECT user AS userid,
                   struct( last(eventtime) AS last_eventtime,
                           last(status) AS last_status,
                           offer_id,
                           subsid AS subscription_id)
                   AS subscription
             FROM (
                   SELECT _lumaservices3.msftidentities.userid user
                        , _lumaservices3.subscription.subscription_id subsid
                        , _lumaservices3.subscription.subscription_status status
                        , _lumaservices3.subscription.offer_id offer_id
                        , TIMESTAMP eventtime

                   FROM
                        xbox_subscription_event
                   UNION
                   SELECT _lumaservices3.msftidentities.userid user
                        , _lumaservices3.subscription.subscription_id subsid
                        , _lumaservices3.subscription.subscription_status status
                        , _lumaservices3.subscription.offer_id offer_id
                        , TIMESTAMP eventtime
                   FROM
                        office365_subscription_event
             )
             GROUP BY user,subsid,offer_id
             ORDER BY user ASC
       ) GROUP BY userid)

초기 데이터 집합 final_subscription_test2에서 구조체 데이터 형식은 subscription 필드와 각 사용자에 고유한 userid을(를) 모두 포함하는 데 사용됩니다. subscription 필드는 사용자의 제품 구독을 설명합니다. 여러 구독이 있을 수 있지만 테이블에는 행당 하나의 구독에 대한 정보만 포함될 수 있습니다.

INSERT INTO를 사용하여 중첩된 데이터 필드 업데이트

final_subscription_test2 데이터 집합이 만들어진 후에는 INSERT INTO 문을 사용하여 테이블에 추가 데이터를 추가합니다. 데이터를 복사할 때에는 소스와 타겟의 데이터 유형이 일치해야 합니다. 또는 원본 데이터 형식이 대상 데이터 형식에 대해 CAST이어야 합니다. 그런 다음 증분 데이터가 다음 SQL을 사용하여 대상 데이터 세트에 추가됩니다.

INSERT INTO final_subscription_test
      SELECT struct(userid, collect_set(subscription) AS subscription) AS _lumaservices3 FROM(
            SELECT user AS userid,
                   struct( last(eventtime) AS last_eventtime,
                           last(status) AS last_status,
                           offer_id,
                           subsid AS subscription_id)
                   AS subscription
             FROM  SELECT _lumaservices3.msftidentities.userid user
                        , _lumaservices3.subscription.subscription_id subsid
                        , _lumaservices3.subscription.subscription_status status
                        , _lumaservices3.subscription.offer_id offer_id
                        , TIMESTAMP eventtime

                   FROM
                        xbox_subscription_event
                   UNION
                   SELECT _lumaservices3.msftidentities.userid user
                        , _lumaservices3.subscription.subscription_id subsid
                        , _lumaservices3.subscription.subscription_status status
                        , _lumaservices3.subscription.offer_id offer_id
                        , timestamp eventtime
                   FROM
                        office365_subscription_event
             )
             GROUP BY user,subsid,offer_id
             ORDER BY user ASC
       ) GROUP BY userid)