Delen via

Een Azure Stream Analytics-taak starten

  • Artikel

U kunt uw Azure Stream Analytics-taak starten met behulp van Azure Portal, Visual Studio en PowerShell. Wanneer u een taak start, selecteert u een tijd voor de taak om uitvoer te maken. Azure Portal, Visual Studio en PowerShell hebben elk verschillende methoden voor het instellen van de begintijd. Deze methoden worden hieronder beschreven.

Startopties

De drie volgende opties zijn beschikbaar om een taak te starten. Houd er rekening mee dat alle tijden die hieronder worden vermeld, de tijden zijn die zijn opgegeven in TIMESTAMP BY. Als TIMESTAMP BY niet is opgegeven, wordt de aankomsttijd gebruikt.

  • Nu: maakt het beginpunt van de uitvoer gebeurtenisstroom hetzelfde als wanneer de taak wordt gestart. Als een tijdelijke operator wordt gebruikt (bijvoorbeeld tijdvenster, LAG of JOIN), kijkt Azure Stream Analytics automatisch terug naar de gegevens in de invoerbron. Als u bijvoorbeeld een taak 'Nu' start en als uw query een tumblingvenster van 5 minuten gebruikt, zoekt Azure Stream Analytics gegevens van 5 minuten geleden in de invoer. De eerste mogelijke uitvoergebeurtenis zou een tijdstempel hebben die gelijk is aan of groter is dan de huidige tijd, en ASA garandeert dat alle invoergebeurtenissen waarvoor logisch kan worden bijgedragen aan de uitvoer, zijn verwerkt. Er worden bijvoorbeeld geen gedeeltelijke vensteraggregaties gegenereerd. Dit is altijd de volledige geaggregeerde waarde.

  • Aangepast: U kunt het beginpunt van de uitvoer kiezen. Net als bij de optie Nu leest Azure Stream Analytics automatisch de gegevens vóór deze tijd als er een tijdelijke operator wordt gebruikt

  • Wanneer het laatst is gestopt. Deze optie is beschikbaar wanneer de taak eerder is gestart, maar handmatig is gestopt of mislukt. Wanneer u deze optie kiest, gebruikt Azure Stream Analytics de laatste uitvoertijd om de taak opnieuw op te starten, zodat er geen gegevens verloren gaan. Net als bij eerdere opties leest Azure Stream Analytics de gegevens vóór deze tijd automatisch als er een tijdelijke operator wordt gebruikt. Aangezien verschillende invoerpartities mogelijk verschillende tijd hebben, wordt de vroegste stoptijd van alle partities gebruikt, waardoor sommige duplicaten in de uitvoer kunnen worden gezien. Meer informatie over exactly-once verwerking vindt u op de pagina Garanties voor gebeurtenislevering.

Azure Portal

Navigeer naar uw taak in Azure Portal en selecteer Start op de overzichtspagina. Selecteer de begintijd van de taakuitvoer en selecteer vervolgens Start.

Kies een van de opties voor de begintijd van taakuitvoer. De opties zijn Nu, Aangepast en, als de taak eerder is uitgevoerd, wanneer de laatste is gestopt. Zie hierboven voor meer informatie over deze opties.

Visual Studio

Selecteer in de taakweergave de groene pijlknop om de taak te starten. Stel de startmodus van de taakuitvoer in en selecteer Start. De taakstatus wordt gewijzigd in Actief.

Er zijn drie opties voor de startmodus taakuitvoer: JobStartTime, CustomTime en LastOutputEventTime. Als deze eigenschap afwezig is, is de standaardwaarde JobStartTime. Zie hierboven voor meer informatie over deze opties.

Powershell

Gebruik de volgende cmdlet om uw taak te starten met behulp van PowerShell:

Start-AzStreamAnalyticsJob `
  -ResourceGroupName $resourceGroup `
  -Name $jobName `
  -OutputStartMode 'JobStartTime'

Er zijn drie opties voor OutputStartMode: JobStartTime, CustomTime en LastOutputEventTime. Als deze eigenschap afwezig is, is de standaardwaarde JobStartTime. Zie hierboven voor meer informatie over deze opties.

Bekijk de naslaginformatie over Start-AzStreamAnalyticsJob voor meer informatie over de Start-AzStreamAnalyticsJob cmdlet.

Volgende stappen