Fabric Data Factory의 트리거를 사용하면 파일 이벤트, 작업 이벤트 및 작업 영역 이벤트를 비롯한 다양한 이벤트에서 파이프라인을 호출할 수 있습니다. Data Factory 데이터 파이프라인을 호출하는 일반적인 사용 사례는 파일 도착 및 파일 삭제와 같은 이벤트에 따라 파이프라인을 트리거하는 것입니다. ADF(Azure Data Factory)에서 Microsoft Fabric으로 이동하는 고객의 경우 ADLS/Blob Storage 이벤트를 사용하는 것이 일반적입니다. 이전에 ADF에 익숙하지 않은 새 패브릭 사용자는 일반적으로 OneLake의 파일 이벤트를 사용할 수 있습니다. Fabric Data Factory의 트리거는 eventstreams 및 Data Activator 경고를 비롯한 패브릭 플랫폼 기능을 사용합니다. Fabric Data Factory 파이프라인 디자인 캔버스 내에는 파이프라인에 대한 데이터 활성화기 경고를 만들고 관리하는 데 사용되는 트리거 단추가 있거나 패브릭 정품 인증기 Real-Time Intelligence 환경에서 직접 트리거를 만들 수 있습니다.
파이프라인에서 스토리지 이벤트 트리거를 설정하는 방법
파이프라인 캔버스 편집기 창 상단에 있는 홈 리본에서 트리거 버튼을 선택합니다.
데이터 활성화기 경고 서비스를 사용하여 트리거에 대한 원본 이벤트를 정의할 수 있는 경고 설정 패널이 열립니다.
여기서는 수신 대기하려는 이벤트 유형을 선택합니다.
OneLake
파일 이벤트, Azure Blob 등을 위한OneLake
이벤트를 선택합니다.데이터 원본 선택 대화 상자를 보여주는 스크린샷입니다.
원본을 선택한 다음 이벤트를 선택하여 트리거에서 수신 대기하려는 스토리지 이벤트를 선택합니다.
Azure 구독 및 Blob Storage 계정 이름을 선택합니다.
패브릭 작업 영역에 새 eventstream 개체가 만들어지므로 Stream 세부 정보에서 올바른 작업 영역을 선택해야 합니다.
다음을 선택합니다.
이벤트 유형을 선택합니다. 파일을 만들고 파일을 삭제하는 것 외에 선택할 수 있는 이벤트 옵션이 더 많이 있음을 알 수 있습니다.
제목 필드를 사용하여 폴더 이름, 파일 이름, 파일 형식, 컨테이너를 지정하고 일치하는 파일 및 폴더로 이벤트를 필터링할 수 있습니다.
이벤트에는 다음과 같은 최상위 데이터가 있습니다.
재산 유형 설명 예시 source 문자열 이벤트 원본에 대한 전체 리소스 경로입니다. 이 필드는 쓸 수 없습니다. Event Grid는 이 값을 제공합니다. /subscriptions/{subscription-id}/resourceGroups/Storage/providers/Microsoft.Storage/storageAccounts/my-storage-account 제목 문자열 게시자가 정의한 이벤트 주제의 경로입니다. /blobServices/default/containers/my-file-system/blobs/new-file.txt 유형 문자열 이 이벤트 원본에 대해 등록된 이벤트 유형 중 하나입니다. Microsoft.Storage.Blob 생성됨 시간 문자열 공급자의 UTC 시간을 기준으로 이벤트가 생성되는 시간입니다. 2017-06-26T18:41:00.9584103Z 아이디 문자열 이벤트에 대한 고유 식별자입니다. 00000000-0000-0000-0000-000000000000 데이터 객체 Blob Storage 이벤트 데이터입니다. {{데이터 객체}} specversion 문자열 CloudEvents 스키마 사양 버전입니다. 1.0 비고
파일 이름 및 폴더 이름은 제목 필드의 일부가 됩니다.
트리거 구성 패널로 돌아가서 트리거 항목, 파이프라인 이름, 파이프라인 작업, 트리거 이름을 항목 이름을 사용하여 Reflex 항목으로 저장할 작업 영역을 선택합니다.
Create를 선택하여 트리거를 만듭니다. 이제 트리거가 파이프라인에서 활성화되고 이를 위해 정의한 스토리지 이벤트에 반응합니다.
트리거를 보려면 작업 영역 목록 보기로 이동하고 패브릭 브라우저에서 이름으로 Reflex 개체를 찾습니다.
개체 형식은 Reflex입니다.
트리거를 선택하여 보고 편집할 Reflex 개체를 엽니다.
파이프라인의 일부인 트리거를 확인하려면 파이프라인 메뉴에서 "트리거 > 보기"를 사용할 수 있습니다.
트리거 파일 이름 및 폴더 이름으로 식 값 설정
파이프라인 내에서 기본 제공 트리거 매개 변수를 사용하여 스토리지 이벤트에서 파일 및 폴더 경로의 이름을 활용할 수 있습니다. Data Factory는 스토리지 이벤트를 수신할 때 이러한 매개 변수를 설정합니다. Blob 경로 및 파일 이름 매개 변수는 트리거 활성화에 의해 설정됩니다. 파이프라인 내 식 작성기에서 트리거 매개 변수 탭을 선택하고 Data Factory는 파일 이름과 폴더 이름을 자동으로 구문 분석하여 파이프라인 식에 동적으로 추가할 수 있게 합니다.
이러한 기본 제공 매개 변수는 도착하는 파일 이벤트의 제목 및 주제 필드에서 설정되며 파이프라인 논리에서 사용할 수 있도록 자동으로 만들어집니다.
@pipeline()?.TriggerEvent?.FileName
파이프라인 식 언어에서 NULL 값을 처리하는 데 사용되는 메서드인 파이프라인() 개체 참조 후에 ?를 사용하는 것을 볼 수 있습니다. 수동 테스트 중에 파일 및 폴더 이름 매개 변수가 설정되지 않아 NULL 값을 반환하므로 트리거 매개 변수를 사용하는 파이프라인을 테스트할 때 이 구문이 필요합니다. 그러나 파일 이벤트에서 파이프라인을 트리거하면 해당 필드에 파일 이름과 폴더 이름이 채워집니다.