다음을 통해 공유

Invoke-AzSynapseSparkStatement

  • 참조
모듈:
Az.Synapse

Synapse Analytics Spark 문을 호출합니다.

구문

Invoke-AzSynapseSparkStatement
      -WorkspaceName <String>
      -SparkPoolName <String>
      -Language <String>
      -SessionId <Int32>
      -FilePath <String>
      [-Response]
      [-AsJob]
      [-DefaultProfile <IAzureContextContainer>]
      [-WhatIf]
      [-Confirm]
      [<CommonParameters>]
Invoke-AzSynapseSparkStatement
      -WorkspaceName <String>
      -SparkPoolName <String>
      -Language <String>
      -SessionId <Int32>
      -Code <String>
      [-Response]
      [-AsJob]
      [-DefaultProfile <IAzureContextContainer>]
      [-WhatIf]
      [-Confirm]
      [<CommonParameters>]
Invoke-AzSynapseSparkStatement
      -Language <String>
      -SessionObject <PSSynapseSparkSession>
      [-SessionId <Int32>]
      -Code <String>
      [-Response]
      [-AsJob]
      [-DefaultProfile <IAzureContextContainer>]
      [-WhatIf]
      [-Confirm]
      [<CommonParameters>]
Invoke-AzSynapseSparkStatement
      -Language <String>
      -SessionObject <PSSynapseSparkSession>
      [-SessionId <Int32>]
      -FilePath <String>
      [-Response]
      [-AsJob]
      [-DefaultProfile <IAzureContextContainer>]
      [-WhatIf]
      [-Confirm]
      [<CommonParameters>]

Description

Invoke-AzSynapseSparkStatement cmdlet은 Synapse Analytics Spark 문을 호출합니다.

예제

예 1

$session = Start-AzSynapseSparkSession -WorkspaceName ContosoWorkspace -SparkPoolName ContosoSparkPool -Name ContosoSessionName -ExecutorCount 3 -ExecutorSize Small
$session.Language = 'Spark' 
$session | Invoke-AzSynapseSparkStatement -Code 'print("Hello world\n")'

이러한 명령은 Spark 세션을 시작한 다음 파이프라인을 통해 인라인 Spark 문을 호출합니다.

예제 2

Invoke-AzSynapseSparkStatement -SessionId 324 -Language 'Spark' -Code 'print("Hello world\n")'

이러한 명령은 Spark 세션을 시작한 다음 인라인 Spark 문을 호출합니다.

예제 3

$session = Start-AzSynapseSparkSession -WorkspaceName ContosoWorkspace -SparkPoolName ContosoSparkPool -Name ContosoSessionName -ExecutorCount 3 -ExecutorSize Small
$session.Language = 'Spark' 
$session | Invoke-AzSynapseSparkStatement -FilePath 'C:\path\to\code.sc'

이러한 명령은 Spark 세션을 시작한 다음, 파일에서 Spark 문을 호출합니다.

매개 변수

-AsJob

백그라운드에서 cmdlet 실행

형식:SwitchParameter
Position:Named
Default value:None
필수:False
파이프라인 입력 허용:False
와일드카드 문자 허용:False

-Code

실행 코드입니다.

형식:String
Position:Named
Default value:None
필수:True
파이프라인 입력 허용:False
와일드카드 문자 허용:False

-Confirm

cmdlet을 실행하기 전에 확인 메시지가 표시됩니다.

형식:SwitchParameter
별칭:cf
Position:Named
Default value:None
필수:False
파이프라인 입력 허용:False
와일드카드 문자 허용:False

-DefaultProfile

Azure와의 통신에 사용되는 자격 증명, 계정, 테넌트 및 구독입니다.

형식:IAzureContextContainer
별칭:AzContext, AzureRmContext, AzureCredential
Position:Named
Default value:None
필수:False
파이프라인 입력 허용:False
와일드카드 문자 허용:False

-FilePath

실행 코드를 포함하는 로컬 파일 경로를 지정합니다.

형식:String
Position:Named
Default value:None
필수:True
파이프라인 입력 허용:False
와일드카드 문자 허용:False

-Language

실행 코드의 언어입니다.

형식:String
허용되는 값:Spark, Scala, PySpark, Python, SparkDotNet, CSharp, SQL, Spark, Scala, PySpark, Python, SparkDotNet, CSharp, SQL
Position:Named
Default value:None
필수:True
파이프라인 입력 허용:False
와일드카드 문자 허용:False

-Response

전체 응답이 반환되어야 임을 나타냅니다.

형식:SwitchParameter
Position:Named
Default value:None
필수:False
파이프라인 입력 허용:False
와일드카드 문자 허용:False

-SessionId

Spark 세션의 식별자입니다.

형식:Int32
Position:Named
Default value:None
필수:True
파이프라인 입력 허용:False
와일드카드 문자 허용:False

-SessionObject

일반적으로 파이프라인을 통해 전달되는 Spark 세션 입력 개체입니다.

형식:PSSynapseSparkSession
Position:Named
Default value:None
필수:True
파이프라인 입력 허용:True
와일드카드 문자 허용:False

-SparkPoolName

Synapse Spark 풀의 이름입니다.

형식:String
Position:Named
Default value:None
필수:True
파이프라인 입력 허용:False
와일드카드 문자 허용:False

-WhatIf

cmdlet이 실행될 경우 결과 동작을 표시합니다. cmdlet이 실행되지 않습니다.

형식:SwitchParameter
별칭:wi
Position:Named
Default value:None
필수:False
파이프라인 입력 허용:False
와일드카드 문자 허용:False

-WorkspaceName

Synapse 작업 영역의 이름입니다.

형식:String
Position:Named
Default value:None
필수:True
파이프라인 입력 허용:False
와일드카드 문자 허용:False

입력

String

PSSynapseSparkSession

출력

PSSynapseExtendedSparkStatement