Udostępnij przez

Invoke-AzSynapseSparkStatement

Moduł:
Az.Synapse Module

Wywołuje instrukcję platformy Spark usługi Synapse Analytics.

Składnia

RunSparkStatementByCodePathParameterSet (Domyślne) 

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>]

Opis

Polecenie cmdlet Invoke-AzSynapseSparkStatement wywołuje instrukcję platformy Spark usługi Synapse Analytics.

Przykłady

Przykład 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")'

Te polecenia uruchamiają sesję platformy Spark, a następnie wywołują instrukcję wbudowanej platformy Spark za pośrednictwem potoku.

Przykład 2

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

Te polecenia uruchamiają sesję platformy Spark, a następnie wywołują instrukcję wbudowanej platformy Spark.

Przykład 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'

Te polecenia uruchamiają sesję platformy Spark, a następnie wywołują instrukcje platformy Spark w pliku.

Parametry

-AsJob

Uruchamianie polecenia cmdlet w tle

Właściwości parametrów

Typ:SwitchParameter
Wartość domyślna:None
Wspiera dzikie karty:False
DontShow:False

Zbiory parametrów

(All)
Pozycja:Named
Obowiązkowy:False
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False

-Code

Kod wykonywania.

Właściwości parametrów

Typ:String
Wartość domyślna:None
Wspiera dzikie karty:False
DontShow:False

Zbiory parametrów

RunSparkStatementByCodeParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False
RunSparkStatementByCodeAndInputObjectParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False

-Confirm

Prosi o potwierdzenie przed uruchomieniem cmdletu.

Właściwości parametrów

Typ:SwitchParameter
Wartość domyślna:None
Wspiera dzikie karty:False
DontShow:False
Aliasy:por

Zbiory parametrów

(All)
Pozycja:Named
Obowiązkowy:False
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False

-DefaultProfile

Poświadczenia, konto, dzierżawa i subskrypcja używane do komunikacji z platformą Azure.

Właściwości parametrów

Typ:IAzureContextContainer
Wartość domyślna:None
Wspiera dzikie karty:False
DontShow:False
Aliasy:AzContext, AzureRmContext, AzureCredential

Zbiory parametrów

(All)
Pozycja:Named
Obowiązkowy:False
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False

-FilePath

Określa lokalną ścieżkę pliku zawierającą kod wykonywania.

Właściwości parametrów

Typ:String
Wartość domyślna:None
Wspiera dzikie karty:False
DontShow:False

Zbiory parametrów

RunSparkStatementByCodePathParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False
RunSparkStatementByCodePathAndInputObjectParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False

-Language

Język kodu wykonywania.

Właściwości parametrów

Typ:String
Wartość domyślna:None
Akceptowane wartości:Spark, Scala, PySpark, Python, SparkDotNet, CSharp, SQL
Wspiera dzikie karty:False
DontShow:False

Zbiory parametrów

RunSparkStatementByCodePathParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False
RunSparkStatementByCodeParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False

-Response

Wskazuje, że powinna zostać zwrócona pełna odpowiedź.

Właściwości parametrów

Typ:SwitchParameter
Wartość domyślna:None
Wspiera dzikie karty:False
DontShow:False

Zbiory parametrów

(All)
Pozycja:Named
Obowiązkowy:False
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False

-SessionId

Identyfikator sesji platformy Spark.

Właściwości parametrów

Typ:Int32
Wartość domyślna:None
Wspiera dzikie karty:False
DontShow:False

Zbiory parametrów

RunSparkStatementByCodePathParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False
RunSparkStatementByCodeParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False

-SessionObject

Obiekt wejściowy sesji platformy Spark, zwykle przekazywany przez potok.

Właściwości parametrów

Typ:PSSynapseSparkSession
Wartość domyślna:None
Wspiera dzikie karty:False
DontShow:False

Zbiory parametrów

RunSparkStatementByCodeAndInputObjectParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:True
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False
RunSparkStatementByCodePathAndInputObjectParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:True
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False

-SparkPoolName

Nazwa puli platformy Spark usługi Synapse.

Właściwości parametrów

Typ:String
Wartość domyślna:None
Wspiera dzikie karty:False
DontShow:False

Zbiory parametrów

RunSparkStatementByCodePathParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False
RunSparkStatementByCodeParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False

-WhatIf

Pokazuje, co się stanie, jeśli polecenie cmdlet zostanie uruchomione. Cmdlet nie jest uruchomiony.

Właściwości parametrów

Typ:SwitchParameter
Wartość domyślna:None
Wspiera dzikie karty:False
DontShow:False
Aliasy:Wi

Zbiory parametrów

(All)
Pozycja:Named
Obowiązkowy:False
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False

-WorkspaceName

Nazwa obszaru roboczego usługi Synapse.

Właściwości parametrów

Typ:String
Wartość domyślna:None
Wspiera dzikie karty:False
DontShow:False

Zbiory parametrów

RunSparkStatementByCodePathParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False
RunSparkStatementByCodeParameterSet
Pozycja:Named
Obowiązkowy:True
Wartość z pipeline:False
Wartość z pipeline według nazwy właściwości:False
Wartość pozostałych argumentów:False

CommonParameters

To polecenie cmdlet obsługuje typowe parametry: -Debug, -ErrorAction, -ErrorVariable, -InformationAction, -InformationVariable, -OutBuffer, -OutVariable, -PipelineVariable, -ProgressAction, -Verbose, -WarningAction i -WarningVariable. Aby uzyskać więcej informacji, zobacz about_CommonParameters.

Wejścia

String

PSSynapseSparkSession

Wyjść

PSSynapseExtendedSparkStatement