sys.sp_create_event_stream_group (Transact-SQL)

Gilt für: SQL Server 2025 (17.x) Azure SQL-DatenbankAzure SQL Managed InstanceSQL-Datenbank in Microsoft Fabric

Erstellt einen Ereignisgruppenstrom für die Change Event Streaming (CES)- Funktion, die in SQL Server 2025 (17.x) eingeführt wurde.

Hinweis

Das Change Event Streaming befindet sich derzeit in der Vorschau und weist Unterschiede in der Unterstützbarkeit zwischen den Produkten auf. Während der Vorschau kann dieses Feature geändert werden.

Transact-SQL-Syntaxkonventionen

Syntax

sys.sp_create_event_stream_group
    [ @stream_group_name = ] N'stream_group_name'
    , [ @destination_type = ] N'destination_type'
    , [ @destination_location = ] N'destination_location'
    , [ @destination_credential = ] N'destination_credential'
    [ , [ @max_message_size_kb = ] max_message_size_kb ]
    [ , [ @partition_key_scheme = ] N'partition_key_scheme' ]
    [ , [ @partition_key_column_name = ] N'partition_key_column_name' ]
    [ , [ @encoding = ] N'encoding' ]
[ ; ]

Argumente

[ @stream_group_name = ] N'stream_group_name'

Gibt den Namen der Ereignisdatenstromgruppe an, die Sie erstellen möchten. @stream_group_name ist "sysname" ohne Standard und kann nicht sein NULL.

[ @destination_type = ] N'destination_type'

Gibt den Streamingzieltyp an. @destination_type ist "sysname" ohne Standard und kann nicht sein NULL.

Important

Das AMQP-Protokoll ist veraltet. Für neue Stream-Gruppen verwenden AzureEventHubs Sie (Azure SQL-Datenbank) oder AzureEventHubsApacheKafka (Azure SQL Managed Instance, SQL Server 2025). Für Details siehe AMQP-Protokoll-Deprecation.

@destination_type kann einer der folgenden Werte sein:

Wert Unterstützt unter Hinweise
AzureEventHubs Azure SQL-Datenbank,
SQL-Datenbank in Microsoft Fabric		 Der einzige akzeptierte Wert auf diesen Plattformen. Verwendet das Kafka-Protokoll.
AzureEventHubsApacheKafka Azure SQL Managed Instance,
SQL Server 2025		 Empfohlen für neue Stream-Gruppen auf diesen Plattformen. Verwendet das Kafka-Protokoll.
AzureEventHubsAmqp Azure SQL Managed Instance,
SQL Server 2025		 Deprecated. Verwendet das AMQP-Protokoll. Vermeide es bei neuen Stream-Gruppen.

[ @destination_location = ] N'destination_location'

Beschreibt den Azure Event Hubs-Namespace und den Instanznamen. @destination_location ist nvarchar(4000), ohne Standard und kann nicht sein NULL.

Geben Sie für das Apache Kafka-Protokoll den Port an.

[ @destination_credential = ] N'destination_credential'

Gibt den Namen der datenbankbezogenen Anmeldeinformationen an, die verwendet werden sollen. @destination_credential ist "sysname" ohne Standard und kann nicht sein NULL.

[ @max_message_size_kb = ] max_message_size_kb

Wenn angegeben, definiert die maximale CES-Nachrichtengröße in Kilobyte. @max_message_size_kb ist int und kann nicht sein NULL. Die Nachricht wird geteilt, wenn sie die angegebene maximale Größe überschreitet. Dieser Parameter ist optional.

@max_message_size_kb weist die folgenden Merkmale auf:

Wert BESCHREIBUNG
128 (Minimum) Entspricht 128 KB
256 (Standardwert) Entspricht 256 KB
1024 (Maximum) Entspricht 1 MB

Der parameter @max_message_size_kb sollte an den Grenzwerten des Ziels ausgerichtet werden. Die maximale Nachrichtengröße für Azure Event Hubs beträgt beispielsweise 1 MB für die Stufen "Standard" und "Premium". Weitere Informationen finden Sie unter Azure Event Hubs-Kontingente.

[ @partition_key_scheme = ] N'partition_key_scheme'

Definiert den Typ der Partitionierung. @partition_key_scheme ist "sysname" und kann nicht sein NULL.

@partition_key_scheme kann einer der folgenden Werte sein:

Wert BESCHREIBUNG
None (Standardwert) Partitionierung wird nicht angegeben, sodass Ereignisse partitionsbasierten Partitionen vom Event Hub mithilfe einer Roundrobin-Strategie zugewiesen werden.
StreamGroup Die Partitionierung erfolgt über die Datenstromgruppe, sodass alle Tabellen in der Datenstromgruppe auf dieselbe Partition gestreamt werden.
Table Die Partitionierung erfolgt per Tabelle, sodass Ereignisse aus derselben Tabelle in der Stream-Gruppe garantiert an dieselbe Partition gesendet werden. Der Partitionierungsschlüssel ist die interne Tabellenkennung.
Column Die Partitionierung erfolgt durch den Wert der Spalte, die durch den Parameter partition_key_column_name angegeben ist. Ereignisse werden Partitionen basierend auf dem Wert dieser Spalte in der Zeile, für die das Ereignis veröffentlicht wurde, zugewiesen.

[ @partition_key_column_name = ] N'partition_key_column_name'

Definiert, welche Spalte für die Partitionierung verwendet werden soll, wenn @partition_key_scheme festgelegt Columnist. @partition_key_column_name ist "sysname" und kann nicht sein NULL.

Verwenden Sie einen zweiteiligen Namen für die Spalte, die sowohl den Schemanamen als auch den Spaltennamen enthält. Beispielsweise ist dbo.Addressesein gültiger Wert .

[ @encoding = ] N'encoding'

Gibt die Nachrichtencodierung an. @encoding ist "sysname" und kann nicht sein NULL.

@encoding kann einer der folgenden Werte sein:

  • JSON (Standardwert)
  • Binary

Rückgabecodewerte

0 (erfolgreich) oder 1 Fehler.

Erlaubnisse

Ein Benutzer mit CONTROL Datenbankberechtigungen, db_owner Datenbankrollenmitgliedschaft oder sysadmin-Serverrollenmitgliedschaft kann dieses Verfahren ausführen.

Beispiele

Ein. Create event stream group on Azure SQL-Datenbank

EXECUTE sys.sp_create_event_stream_group
    @stream_group_name = N'myStreamGroup',
    @destination_type = N'AzureEventHubs',
    @destination_location = N'myEventHubsNamespace.servicebus.windows.net:9093/myEventHubsInstance',
    @destination_credential = MyDatabaseScopedCredentialForCes;

B. Erstelle eine Event Stream Gruppe auf Azure SQL Managed Instance oder SQL Server 2025

EXECUTE sys.sp_create_event_stream_group
    @stream_group_name = N'myStreamGroup',
    @destination_type = N'AzureEventHubsApacheKafka',
    @destination_location = N'myEventHubsNamespace.servicebus.windows.net:9093/myEventHubsInstance',
    @destination_credential = MyDatabaseScopedCredentialForCes;

Verwandte Inhalte

  • Last updated on