Partilhar via


Invoke-AzSynapseSparkStatement

Invoca uma instrução Synapse Analytics Spark.

Sintaxe

RunSparkStatementByCodePathParameterSet (Padrão)

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

RunSparkStatementByCodeParameterSet

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

RunSparkStatementByCodeAndInputObjectParameterSet

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

RunSparkStatementByCodePathAndInputObjectParameterSet

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

Descrição

O cmdlet Invoke-AzSynapseSparkStatement invoca uma instrução Synapse Analytics Spark.

Exemplos

Exemplo 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")'

Esses comandos iniciam uma sessão do Spark e, em seguida, invocam uma instrução Spark embutida através do pipeline.

Exemplo 2

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

Esses comandos iniciam uma sessão do Spark e, em seguida, invocam uma instrução Spark embutida.

Exemplo 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'

Esses comandos iniciam uma sessão do Spark e, em seguida, invocam instruções do Spark em um arquivo.

Parâmetros

-AsJob

Executar cmdlet em segundo plano

Propriedades dos parâmetros

Tipo:SwitchParameter
Valor padrão:None
Suporta curingas:False
DontShow:False

Conjuntos de parâmetros

(All)
Posição:Named
Obrigatório:False
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False

-Code

O código de execução.

Propriedades dos parâmetros

Tipo:String
Valor padrão:None
Suporta curingas:False
DontShow:False

Conjuntos de parâmetros

RunSparkStatementByCodeParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False
RunSparkStatementByCodeAndInputObjectParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False

-Confirm

Solicita confirmação antes de executar o cmdlet.

Propriedades dos parâmetros

Tipo:SwitchParameter
Valor padrão:None
Suporta curingas:False
DontShow:False
Pseudónimos:Cf.

Conjuntos de parâmetros

(All)
Posição:Named
Obrigatório:False
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False

-DefaultProfile

As credenciais, a conta, o locatário e a assinatura usados para comunicação com o Azure.

Propriedades dos parâmetros

Tipo:IAzureContextContainer
Valor padrão:None
Suporta curingas:False
DontShow:False
Pseudónimos:AzContext, AzureRmContext, AzureCredential

Conjuntos de parâmetros

(All)
Posição:Named
Obrigatório:False
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False

-FilePath

Especifica um caminho de arquivo local que contém o código de execução.

Propriedades dos parâmetros

Tipo:String
Valor padrão:None
Suporta curingas:False
DontShow:False

Conjuntos de parâmetros

RunSparkStatementByCodePathParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False
RunSparkStatementByCodePathAndInputObjectParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False

-Language

Idioma do código de execução.

Propriedades dos parâmetros

Tipo:String
Valor padrão:None
Valores aceites:Spark, Scala, PySpark, Python, SparkDotNet, CSharp, SQL
Suporta curingas:False
DontShow:False

Conjuntos de parâmetros

RunSparkStatementByCodePathParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False
RunSparkStatementByCodeParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False

-Response

Indica que a resposta completa deve ser devolvida.

Propriedades dos parâmetros

Tipo:SwitchParameter
Valor padrão:None
Suporta curingas:False
DontShow:False

Conjuntos de parâmetros

(All)
Posição:Named
Obrigatório:False
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False

-SessionId

Identificador da sessão do Spark.

Propriedades dos parâmetros

Tipo:Int32
Valor padrão:None
Suporta curingas:False
DontShow:False

Conjuntos de parâmetros

RunSparkStatementByCodePathParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False
RunSparkStatementByCodeParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False

-SessionObject

Objeto de entrada de sessão de faísca, geralmente passado pelo pipeline.

Propriedades dos parâmetros

Tipo:PSSynapseSparkSession
Valor padrão:None
Suporta curingas:False
DontShow:False

Conjuntos de parâmetros

RunSparkStatementByCodeAndInputObjectParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:True
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False
RunSparkStatementByCodePathAndInputObjectParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:True
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False

-SparkPoolName

Nome da piscina Synapse Spark.

Propriedades dos parâmetros

Tipo:String
Valor padrão:None
Suporta curingas:False
DontShow:False

Conjuntos de parâmetros

RunSparkStatementByCodePathParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False
RunSparkStatementByCodeParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False

-WhatIf

Mostra o que aconteceria se o cmdlet fosse executado. O cmdlet não é executado.

Propriedades dos parâmetros

Tipo:SwitchParameter
Valor padrão:None
Suporta curingas:False
DontShow:False
Pseudónimos:Wi

Conjuntos de parâmetros

(All)
Posição:Named
Obrigatório:False
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False

-WorkspaceName

Nome do espaço de trabalho Sinapse.

Propriedades dos parâmetros

Tipo:String
Valor padrão:None
Suporta curingas:False
DontShow:False

Conjuntos de parâmetros

RunSparkStatementByCodePathParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False
RunSparkStatementByCodeParameterSet
Posição:Named
Obrigatório:True
Valor do pipeline:False
Valor do pipeline por nome da propriedade:False
Valor dos argumentos restantes:False

CommonParameters

Este cmdlet suporta os parâmetros comuns: -Debug, -ErrorAction, -ErrorVariable, -InformationAction, -InformationVariable, -OutBuffer, -OutVariable, -PipelineVariable, -ProgressAction, -Verbose, -WarningAction e -WarningVariable. Para obter mais informações, consulte about_CommonParameters.

Entradas

String

PSSynapseSparkSession

Saídas

PSSynapseExtendedSparkStatement