Microsoft.Azure.WebJobs.Extensions.WebPubSub
1.8.0
Prefix Reserved
dotnet add package Microsoft.Azure.WebJobs.Extensions.WebPubSub --version 1.8.0
NuGet\Install-Package Microsoft.Azure.WebJobs.Extensions.WebPubSub -Version 1.8.0
<PackageReference Include="Microsoft.Azure.WebJobs.Extensions.WebPubSub" Version="1.8.0" />
paket add Microsoft.Azure.WebJobs.Extensions.WebPubSub --version 1.8.0
#r "nuget: Microsoft.Azure.WebJobs.Extensions.WebPubSub, 1.8.0"
// Install Microsoft.Azure.WebJobs.Extensions.WebPubSub as a Cake Addin #addin nuget:?package=Microsoft.Azure.WebJobs.Extensions.WebPubSub&version=1.8.0 // Install Microsoft.Azure.WebJobs.Extensions.WebPubSub as a Cake Tool #tool nuget:?package=Microsoft.Azure.WebJobs.Extensions.WebPubSub&version=1.8.0
Azure WebJobs Web PubSub client library for .NET
This extension provides functionality for receiving Web PubSub webhook calls in Azure Functions, allowing you to easily write functions that respond to any event published to Web PubSub.
Source code | Package | API reference documentation | Product documentation | Samples
Getting started
Install the package
Install the Web PubSub extension with NuGet:
dotnet add package Microsoft.Azure.WebJobs.Extensions.WebPubSub
Prerequisites
You must have an Azure subscription and an Azure resource group with a Web PubSub resource. Follow this step-by-step tutorial to create an Azure Web PubSub instance.
Authenticate the client
In order to let the extension work with Azure Web PubSub service, you will need to provide a valid ConnectionString
.
You can find the Keys for you Azure Web PubSub service in the Azure Portal.
The AzureWebJobsStorage
connection string is used to preserve the processing checkpoint information as required refer to Storage considerations
For the local development use the local.settings.json
file to store the connection string, <connection-string>
can be set to WebPubSubConnectionString
as default supported in the extension, or you can set customized names by mapping it with Connection = <connection-string>
in function binding attributes:
{
"Values": {
"AzureWebJobsStorage": "UseDevelopmentStorage=true",
"<connection-string>": "Endpoint=https://<webpubsub-name>.webpubsub.azure.com;AccessKey=<access-key>;Version=1.0;"
}
}
When deployed use the application settings to set the connection string.
Key concepts
Using Web PubSub input binding
Please follow the input binding tutorial to learn about using this extension for building WebPubSubConnection
to create Websockets connection to service with input binding.
Using Web PubSub output binding
Please follow the output binding tutorial to learn about using this extension for publishing Web PubSub messages.
Using Web PubSub trigger
Please follow the trigger binding tutorial to learn about triggering an Azure Function when an event is sent from service upstream.
In Connect
and UserEvent
events, function will respect return values to send back service. Then service will depend on the response to proceed the request or else. The responses and events are paired. For example, Connect
will only respect ConnectEventResponse
or EventErrorResponse
, and ignore other returns. When EventErrorResponse
is returned, service will drop client connection. Please follow the trigger binding return value tutorial to learn about using the trigger return value.
Examples
Functions that uses Web PubSub input binding
public static class WebPubSubConnectionBindingFunction
{
[FunctionName("WebPubSubConnectionBindingFunction")]
public static WebPubSubConnection Run(
[HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequest req,
[WebPubSubConnection(Hub = "hub", UserId = "{query.userid}", Connection = "<connection-string>")] WebPubSubConnection connection)
{
Console.WriteLine("login");
return connection;
}
}
Functions that uses Web PubSub output binding
public static class WebPubSubOutputBindingFunction
{
[FunctionName("WebPubSubOutputBindingFunction")]
public static async Task RunAsync(
[HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequest req,
[WebPubSub(Hub = "hub", Connection = "<connection-string>")] IAsyncCollector<WebPubSubAction> action)
{
await action.AddAsync(WebPubSubAction.CreateSendToAllAction("Hello Web PubSub!", WebPubSubDataType.Text));
}
}
Functions that uses Web PubSub trigger
[FunctionName("WebPubSubTriggerFunction")]
public static void Run(
ILogger logger,
[WebPubSubTrigger("hub", WebPubSubEventType.User, "message")] UserEventRequest request,
string data,
WebPubSubDataType dataType)
{
logger.LogInformation("Request from: {user}, data: {data}, dataType: {dataType}",
request.ConnectionContext.UserId, data, dataType);
}
Functions that uses Web PubSub trigger return value
public static class WebPubSubTriggerReturnValueFunction
{
[FunctionName("WebPubSubTriggerReturnValueFunction")]
public static UserEventResponse Run(
[WebPubSubTrigger("hub", WebPubSubEventType.User, "message")] UserEventRequest request)
{
return request.CreateResponse(BinaryData.FromString("ack"), WebPubSubDataType.Text);
}
}
Functions that handles MQTT Client "connect" event
[FunctionName("mqttConnect")]
public static WebPubSubEventResponse Run(
[WebPubSubTrigger("hub", WebPubSubEventType.System, "connect", ClientProtocols = WebPubSubTriggerAcceptedClientProtocols.Mqtt)] MqttConnectEventRequest request,
ILogger log)
{
if (request.ConnectionContext.ConnectionId != "attacker")
{
return request.CreateMqttResponse(request.ConnectionContext.UserId, Array.Empty<string>(), new string[] { "webpubsub.joinLeaveGroup.group1", "webpubsub.sendToGroup.group2" });
}
else
{
if (request.Mqtt.ProtocolVersion == MqttProtocolVersion.V311)
{
return request.CreateMqttV311ErrorResponse(MqttV311ConnectReturnCode.NotAuthorized);
}
else
{
return request.CreateMqttV50ErrorResponse(MqttV500ConnectReasonCode.NotAuthorized);
}
}
}
Troubleshooting
Please refer to Monitor Azure Functions for troubleshooting guidance.
Next steps
Read the introduction to Azure Function or creating an Azure Function guide.
Contributing
See our CONTRIBUTING.md for details on building, testing, and contributing to this library.
This project welcomes contributions and suggestions. Most contributions require you to agree to a Contributor License Agreement (CLA) declaring that you have the right to, and actually do, grant us the rights to use your contribution. For details, visit cla.microsoft.com.
This project has adopted the Microsoft Open Source Code of Conduct. For more information see the Code of Conduct FAQ or contact opencode@microsoft.com with any additional questions or comments.
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net5.0 was computed. net5.0-windows was computed. net6.0 was computed. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 was computed. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. |
.NET Core | netcoreapp2.0 was computed. netcoreapp2.1 was computed. netcoreapp2.2 was computed. netcoreapp3.0 was computed. netcoreapp3.1 was computed. |
.NET Standard | netstandard2.0 is compatible. netstandard2.1 was computed. |
.NET Framework | net461 was computed. net462 was computed. net463 was computed. net47 was computed. net471 was computed. net472 was computed. net48 was computed. net481 was computed. |
MonoAndroid | monoandroid was computed. |
MonoMac | monomac was computed. |
MonoTouch | monotouch was computed. |
Tizen | tizen40 was computed. tizen60 was computed. |
Xamarin.iOS | xamarinios was computed. |
Xamarin.Mac | xamarinmac was computed. |
Xamarin.TVOS | xamarintvos was computed. |
Xamarin.WatchOS | xamarinwatchos was computed. |
-
.NETStandard 2.0
- Azure.Messaging.WebPubSub (>= 1.4.0)
- Microsoft.AspNetCore.Http (>= 2.1.22)
- Microsoft.Azure.WebJobs (>= 3.0.37)
- Microsoft.Azure.WebPubSub.Common (>= 1.3.0)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last updated |
---|---|---|
1.8.0 | 2,246 | 9/4/2024 |
1.7.0 | 52,804 | 8/30/2023 |
1.6.0 | 6,650 | 7/13/2023 |
1.5.0 | 32,994 | 4/13/2023 |
1.4.0 | 10,684 | 2/2/2023 |
1.3.0 | 12,909 | 11/11/2022 |
1.2.0 | 36,422 | 3/10/2022 |
1.1.0 | 17,737 | 12/9/2021 |
1.0.0 | 2,866 | 11/12/2021 |
1.0.0-beta.4 | 1,412 | 10/28/2021 |
1.0.0-beta.3 | 4,608 | 7/26/2021 |
1.0.0-beta.2 | 370 | 7/15/2021 |
1.0.0-beta.1 | 3,436 | 4/27/2021 |