Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Gäller för: SQL Server 2025 (17.x)
Azure SQL Database
Azure SQL Managed Instance
SQL-databas i Microsoft Fabric
Skapar en händelsegruppström för funktionen change event streaming (CES) som introducerades i SQL Server 2025 (17.x).
Anmärkning
Strömningen av förändringshändelser är för närvarande i förhandsvisning och har skillnader i supportmöjligheter mellan produkterna. Den här funktionen kan komma att ändras under förhandsversionen.
Transact-SQL syntaxkonventioner
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' ]
[ ; ]
Argumentpunkter
[ @stream_group_name = ] N'stream_group_name'
Anger namnet på den händelseströmsgrupp som du vill skapa.
@stream_group_name är sysname, utan standard och kan inte vara NULL.
[ @destination_type = ] N'destination_type'
Anger måltypen för direktuppspelning.
@destination_type är sysname, utan standard och kan inte vara NULL.
Important
AMQP-protokollet är föråldrat. För nya strömgrupper, använd AzureEventHubs (Azure SQL Database) eller AzureEventHubsApacheKafka (Azure SQL Managed Instance, SQL Server 2025). För detaljer, se AMQP-protokollets avveckling.
@destination_type kan vara något av följande värden:
| Värde | Stöds på | Noteringar |
|---|---|---|
AzureEventHubs |
Azure SQL Database, SQL-databas i Microsoft Fabric |
Det enda accepterade värdet på dessa plattformar. Använder Kafka-protokollet. |
AzureEventHubsApacheKafka |
Azure SQL Managed Instance, SQL Server 2025 |
Rekommenderas för nya streamgrupper på dessa plattformar. Använder Kafka-protokollet. |
AzureEventHubsAmqp |
Azure SQL Managed Instance, SQL Server 2025 |
Deprecated. Använder AMQP-protokollet. Undvik för nya strömgrupper. |
[ @destination_location = ] N'destination_location'
Beskriver Azure Event Hubs-namnområdet och instansnamnet.
@destination_location är nvarchar(4000), utan standard och kan inte vara NULL.
För Apache Kafka-protokollet anger du porten.
[ @destination_credential = ] N'destination_credential'
Anger namnet på databasomfattningen för autentiseringsuppgifter som ska användas.
@destination_credential är sysname, utan standard och kan inte vara NULL.
[ @max_message_size_kb = ] max_message_size_kb
Om det anges definierar du den maximala CES-meddelandestorleken i kilobyte.
@max_message_size_kb är int och kan inte vara NULL. Meddelandet delas om det överskrider den angivna maxstorleken. Den här parametern är valfri.
@max_message_size_kb har följande egenskaper:
| Värde | Beskrivning |
|---|---|
128 (minimum) |
Motsvarar 128 KB |
256 (standardinställning) |
Motsvarar 256 KB |
1024 (max) |
Motsvarar 1 MB |
Parametern @max_message_size_kb bör justeras till målets gränser. Den maximala meddelandestorleken för Azure Event Hubs är till exempel 1 MB för nivåerna Standard och Premium. Mer information finns i kvoter för Azure Event Hubs.
[ @partition_key_scheme = ] N'partition_key_scheme'
Definierar typen av partitionering.
@partition_key_scheme är sysname och får inte vara NULL.
@partition_key_scheme kan vara något av följande värden:
| Värde | Beskrivning |
|---|---|
None (standardinställning) |
Partitionering anges inte, så händelser tilldelas till partitioner av händelsehubben med hjälp av en strategi för resursallokering. |
StreamGroup |
Partitionering görs efter strömgrupp så att alla tabeller i strömgruppen strömmas till samma partition. |
Table |
Partitionering görs per tabell så att händelser från samma tabell i strömgruppen garanteras skickas till samma partition. Partitioneringsnyckeln är den interna tabellidentifieraren. |
Column |
Partitionering görs med värdet på kolumnen som anges av parametern partition_key_column_name . Händelser tilldelas partitioner baserat på kolumnens värde i raden där händelsen publiceras. |
[ @partition_key_column_name = ] N'partition_key_column_name'
Definierar vilken kolumn som ska användas för partitionering när @partition_key_scheme är inställt på Column.
@partition_key_column_name är sysname och får inte vara NULL.
Använd ett tvådelade namn för kolumnen som innehåller både schemanamnet och kolumnnamnet. Ett giltigt värde är dbo.Addressestill exempel .
[ @encoding = ] N'encoding'
Anger meddelandekodningen.
@encoding är sysname och kan inte vara NULL.
@encoding kan vara något av följande värden:
-
JSON(standardinställning) Binary
Returnera kodvärden
0 (lyckades) eller 1 (fel).
Behörigheter
En användare med CONTROL databasbehörigheter, db_owner databasrollmedlemskap eller sysadmin-serverrollmedlemskap kan utföra den här proceduren.
Exempel
A. Create event stream group on Azure SQL Database
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. Skapa event stream-grupp på Azure SQL Managed Instance eller 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;