Fabric 사용자 데이터 함수(User Data Function) (2)

 

Fabric 사용자 데이터 함수(User Data Function) (2) – 데이터 조회 및 변경

 

데이터 파이프라인과 노트북, Power BI 등에서 Fabric UDF를 이용할 수 있습니다. Python 코드에서 데이터베이스(레이크하우스, SQL 데이터베이스)를 연결하여 데이터를 조회, 변경, 삭제 등을 수행할 수 있습니다.

예를 들어, 데이터 파이프라인으로 데이터를 가져와서 저장 후 데이터 파이프라인, 노트북에서 이메일이나 카드 번호를 마스킹하는 UDF를 호출하여 데이터를 변경하도록 할 수 있습니다. Power BI의 텍스트 슬라이서에서 판매 종료, 할인을 적용할 제품을 선택하여 UDF를 호출하여 제품의 상태 코드, 할인율을 업데이트할 수 있습니다. 또는 임직원의 매니저 메일 주소를 테이블에서 조회하여 메일을 발송할 수도 있습니다.

 

먼저, 제품의 상태 값을 업데이트해보겠습니다. 여기서는 Fabric의 SQL 데이터베이스를 이용합니다. 웨어하우스와 레이크하우스의 구문은 Client 클래스가 일부 상이하고 나머지 코드는 거의 동일합니다.

직접 코드를 작성하여도 되지만, [편집] 리본의 [샘플 삽입]에서 코드를 추가하고, 상황에 맞게 바꾸는 것이 적절합니다. [SQL Database], [Write one row of data into a table in SQL database]를 선택합니다.

사용자 데이터 함수에서 한 줄 주석은 #, 여러 줄 주석은 ‘’’ 를 앞뒤로 처리하면 됩니다.

@udf.connection의 <> 부분을 변경해야 합니다. [편집] 리본의 [연결 관리] 메뉴를 클릭하여 데이터베이스 연결을 추가합니다. 코드의 <> 부분을 연결의 별칭 이름으로 변경합니다.

그리고 함수 이름과 매개변수를 상황에 맞게 변경하고, 주석과 SQL 구문을 변경합니다.

SQL 구문에서 매개변수로 처리되는 값은 ? 로 처리하고, 여기서는 data라는 변수에서 순서대로 매개변수를 나열하면 됩니다. ?가 3개면 3개의 매개변수가 있으면 됩니다.

그후에는 execute, commit 함수를 호출하고 close 해야 합니다.

함수를 작성하였다면 함수 탐색기에서 해당 함수에 마우스를 올려 테스트 아이콘을 클릭하여 테스트를 수행합니다. 필요하다면 logging 클래스를 통해 로그를 기록하여 디버깅할 수 있습니다. 실제 데이터베이스에서 변경여부를 최종적으로 확인할 수 있습니다.

 

그럼 데이터를 조회하는 방법을 확인해보겠습니다. 조회한 결과의 반환을 무엇으로 할 지 결정합니다. 여러 열과 행을 가지고 있다면 list로 처리합니다.

Fabric의 SQL 데이터베이스에서 조회하는 샘플 코드를 살펴보면 commit 함수가 없고 결과를 배열에 append하여 반환합니다

테스트해보면 결과를 확인할 수 있습니다.

 

 Power BI의 텍스트 슬라이서에서 판매 종료, 할인을 적용할 제품을 선택하여 제품의 상태 코드, 할인율을 업데이트하고, 관리자에게 메일을 보낼 수 있습니다.

간략히 사용자 데이터 함수에서 데이터원본을 연결하여 조회, 변경하는 방법을 확인해보았습니다. UDF를 잘 활용한다면 업무 프로세스를 간소화할 수 있습니다.