다음을 통해 공유


KQL 데이터베이스의 데이터와 함께 Fabric Notebook 사용

Notebook은 모두 데이터 분석 설명과 결과 및 데이터 분석을 수행하기 위해 실행할 수 있는 실행 가능한 문서를 포함하는 읽을 수 있는 문서입니다. 이 문서에서는 Fabric Notebook을 사용하여 KQL 데이터베이스데이터에 연결하고 네이티브 KQL(Kusto 쿼리 언어)을 사용하여 쿼리를 실행하는 방법을 알아봅니다. Notebook에 대한 자세한 내용은 Microsoft Fabric Notebook을 사용하는 방법을 참조 하세요.

KQL 데이터베이스의 데이터와 함께 Fabric Notebook을 사용하는 방법에는 두 가지가 있습니다.

필수 조건

Notebook에서 Kusto 코드 조각 사용

패브릭 Notebook은 일반적으로 사용되는 코드 패턴을 쉽게 작성하는 데 도움이 되는 코드 조각을 제공합니다. 코드 조각을 사용하여 KQL을 사용하여 KQL 데이터베이스에서 데이터를 쓰거나 읽을 수 있습니다.

  1. 기존 전자 필기장으로 이동하거나 새 전자 필기장을 만듭니다.

  2. 코드 셀에서 kusto 입력을 시작합니다.

    Kusto 코드 조각을 사용하여 Fabric Notebook에서 KQL을 사용하는 화면 캡처입니다.

  3. 수행하려는 작업에 해당하는 코드 조각을 선택합니다. KQL 데이터베이스에 데이터를 쓰거나 KQL 데이터베이스에서 데이터를 읽습니다.

    다음 코드 조각은 예제 데이터 읽기 작업을 보여줍니다.

    # Example of query for reading data from Kusto. Replace T with your <tablename>.
    kustoQuery = "['T'] | take 10"
    # The query URI for reading the data e.g. https://<>.kusto.data.microsoft.com.
    kustoUri = "https://<yourKQLdatabaseURI>.z0.kusto.data.microsoft.com"
    # The database with data to be read.
    database = "DocsDatabase"
    # The access credentials.
    accessToken = mssparkutils.credentials.getToken(kustoUri)
    kustoDf  = spark.read\
        .format("com.microsoft.kusto.spark.synapse.datasource")\
        .option("accessToken", accessToken)\
        .option("kustoCluster", kustoUri)\
        .option("kustoDatabase", database)\
        .option("kustoQuery", kustoQuery).load()
    
    # Example that uses the result data frame.
    kustoDf.show()
    

    다음 코드 조각은 데이터 쓰기 작업의 예제를 보여 있습니다.

    # The Kusto cluster uri to write the data. The query Uri is of the form https://<>.kusto.data.microsoft.com 
    kustoUri = ""
    # The database to write the data
    database = ""
    # The table to write the data 
    table    = ""
    # The access credentials for the write
    accessToken = mssparkutils.credentials.getToken(kustoUri)
    
    # Generate a range of 5 rows with Id's 5 to 9
    data = spark.range(5,10) 
    
    # Write data to a Kusto table
    data.write.\
    format("com.microsoft.kusto.spark.synapse.datasource").\
    option("kustoCluster",kustoUri).\
    option("kustoDatabase",database).\
    option("kustoTable", table).\
    option("accessToken", accessToken ).\
    option("tableCreateOptions", "CreateIfNotExist").mode("Append").save()
    
  4. 데이터 셀에 있는 각 필드의 따옴표 안에 필요한 정보를 입력합니다.

    필드 설명 관련 링크
    kustoQuery 평가할 KQL 쿼리입니다. KQL 개요
    KustoUri KQL 데이터베이스의 쿼리 URI입니다. KQL 데이터베이스 URI 복사
    database KQL 데이터베이스의 이름입니다. 기존 KQL 데이터베이스에 액세스
    데이터 테이블에 쓸 데이터입니다.
  5. 코드 셀을 실행합니다.

KQL 데이터베이스에서 Notebook 만들기

Notebook을 KQL 데이터베이스에서 관련 항목으로 만들면 Notebook에 KQL 데이터베이스와 동일한 이름이 지정되고 연결 정보가 미리 채워집니다.

  1. KQL 데이터베이스로 이동합니다.

  2. 새 관련 항목>Notebook을 선택합니다.

    KQL 데이터베이스에서 Notebook을 관련 항목으로 만드는 스크린샷

    KustoUri 및 데이터베이스 세부 정보가 미리 채워진 Notebook이 만들어집니다.

  3. kustoQuery 필드에서 평가할 KQL 쿼리를 입력합니다.

    KQL 데이터베이스에서 만든 Notebook의 스크린샷

  4. 코드 셀을 실행합니다.