-
Notifications
You must be signed in to change notification settings - Fork 5.1k
ClientModel: Add samples for System.ClientModel library #42369
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Merged
Merged
Changes from 27 commits
Commits
Show all changes
44 commits
Select commit
Hold shift + click to select a range
2737eab
Samples - WIP
annelo-msft e1f7a82
README updates
annelo-msft 6bae518
Merge remote-tracking branch 'upstream/main' into clientmodel-samples
annelo-msft e43c767
Configuration samples
annelo-msft e0fee6f
updates before generating snippets
annelo-msft 9dbf76b
update snippets
annelo-msft 433c3fc
readme updates
annelo-msft a7934ed
intermediate backup
annelo-msft f7adcbf
updates
annelo-msft 2d4ec41
fix
annelo-msft b9e406f
updates
annelo-msft 8408cf3
nit
annelo-msft b316e9c
nit
annelo-msft f0c2877
fix links
annelo-msft 456c6b5
updates from PR feedback
annelo-msft c0db649
revert engsys file
annelo-msft 75d0161
update product
annelo-msft f6c136c
Merge remote-tracking branch 'upstream/main' into clientmodel-samples
annelo-msft 262e923
add sample client implementation
annelo-msft 552b485
add input model to sample client method
annelo-msft d83555e
change API key in samples
annelo-msft 6d99f19
add inline comments to sample client and change defaults on HttpClien…
annelo-msft ee42d04
update impressions link
annelo-msft e8b6e09
restructure to address PR feedback
annelo-msft 81eae19
nits
annelo-msft 095324c
nits
annelo-msft 47a47ca
nits
annelo-msft 4ef9646
Merge remote-tracking branch 'upstream/main' into clientmodel-samples
annelo-msft 91d3223
small updates from PR feedback
annelo-msft 863cec6
add comment
annelo-msft 7a02ba2
rework convenience methods section in README
annelo-msft c9fc7d0
more updates; add dotnet-api slug
annelo-msft f459730
Add sample showing response classifier
annelo-msft 3c75fa9
updates:
annelo-msft 8040105
reference error response configuration sample from README
annelo-msft 24cc903
Merge remote-tracking branch 'upstream/main' into clientmodel-samples
annelo-msft a49b27b
update samples README
annelo-msft 5f00c79
update md files
annelo-msft 49896a6
show creation of BinaryContent from model in RequestOptions sample
annelo-msft 81e2e20
add examples of different way to create BinaryContent
annelo-msft 3aed272
show protocol method implementation and message.Apply(options)
annelo-msft d7a36c7
updates
annelo-msft 6c56e7c
nits
annelo-msft 2719c61
nits
annelo-msft File filter
Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
There are no files selected for viewing
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,98 @@ | ||
| # System.ClientModel-based client configuration samples | ||
|
|
||
| ## Configuring retries | ||
|
|
||
| To modify the retry policy, create a new instance of `ClientRetryPolicy` and set it on the `ClientPipelineOptions` passed to the client constructor. | ||
|
|
||
| By default, clients will retry a request three times using an exponential retry strategy with an initial delay of 0.8 seconds and a maximum delay of one minute. | ||
|
|
||
| ```C# Snippet:ConfigurationCustomizeRetries | ||
| MapsClientOptions options = new() | ||
| { | ||
| RetryPolicy = new ClientRetryPolicy(maxRetries: 5), | ||
| }; | ||
|
|
||
| string? key = Environment.GetEnvironmentVariable("MAPS_API_KEY"); | ||
| ApiKeyCredential credential = new(key!); | ||
| MapsClient client = new(new Uri("https://atlas.microsoft.com"), credential, options); | ||
| ``` | ||
|
|
||
| ## Implement a custom policy | ||
annelo-msft marked this conversation as resolved.
Show resolved
Hide resolved
|
||
|
|
||
| To implement a custom policy that can be added to the client's pipeline, create a class that derives from `PipelinePolicy` and overide its `ProcessAsync` and `Process` methods. The request can be accessed via `message.Request`. The response is accessible via `message.Response`, but will have a value only after `ProcessNextAsync`/`ProcessNext` has been called. | ||
|
|
||
| ```C# Snippet:ConfigurationCustomPolicy | ||
| public class StopwatchPolicy : PipelinePolicy | ||
| { | ||
| public override async ValueTask ProcessAsync(PipelineMessage message, IReadOnlyList<PipelinePolicy> pipeline, int currentIndex) | ||
| { | ||
| Stopwatch stopwatch = new(); | ||
| stopwatch.Start(); | ||
|
|
||
| await ProcessNextAsync(message, pipeline, currentIndex); | ||
|
|
||
| stopwatch.Stop(); | ||
|
|
||
| Console.WriteLine($"Request to {message.Request.Uri} took {stopwatch.Elapsed}"); | ||
| } | ||
|
|
||
| public override void Process(PipelineMessage message, IReadOnlyList<PipelinePolicy> pipeline, int currentIndex) | ||
| { | ||
| Stopwatch stopwatch = new(); | ||
| stopwatch.Start(); | ||
|
|
||
| ProcessNext(message, pipeline, currentIndex); | ||
|
|
||
| stopwatch.Stop(); | ||
|
|
||
| Console.WriteLine($"Request to {message.Request.Uri} took {stopwatch.Elapsed}"); | ||
| } | ||
| } | ||
| ``` | ||
|
|
||
| ## Add a custom policy to the pipeline | ||
|
|
||
| Azure SDKs provides a way to add policies to the pipeline at three positions, `PerCall`, `PerTry`, and `BeforeTransport`. | ||
|
|
||
| - `PerCall` policies run once per request | ||
|
|
||
| ```C# Snippet:ConfigurationAddPerCallPolicy | ||
| MapsClientOptions options = new(); | ||
| options.AddPolicy(new StopwatchPolicy(), PipelinePosition.PerCall); | ||
| ``` | ||
|
|
||
| - `PerTry` policies run each time a request is tried | ||
|
|
||
| ```C# Snippet:ConfigurationAddPerTryPolicy | ||
| options.AddPolicy(new StopwatchPolicy(), PipelinePosition.PerTry); | ||
| ``` | ||
|
|
||
| - `BeforeTransport` policies run after all other policies in the pipeline and before the request is sent by the transport. | ||
|
|
||
| Adding policies at the `BeforeTransport` position should be done with care since changes made to the request by a before-transport policy will not be visible to any logging policies that come before it in the pipeline. | ||
|
|
||
| ```C# Snippet:ConfigurationAddBeforeTransportPolicy | ||
| options.AddPolicy(new StopwatchPolicy(), PipelinePosition.BeforeTransport); | ||
| ``` | ||
|
|
||
| ## Provide a custom HttpClient instance | ||
|
|
||
| In some cases, users may want to provide a custom instance of the `HttpClient` used by a client's transport to send and receive HTTP messages. To provide a custom `HttpClient`, create a new instance of `HttpClientPipelineTransport` and pass the custom `HttpClient` instance to its constructor. | ||
|
|
||
| ```C# Snippet:ConfigurationCustomHttpClient | ||
| using HttpClientHandler handler = new() | ||
| { | ||
| // Reduce the max connections per server, which defaults to 50. | ||
| MaxConnectionsPerServer = 25, | ||
|
|
||
| // Preserve default System.ClientModel redirect behavior. | ||
| AllowAutoRedirect = false, | ||
| }; | ||
|
|
||
| using HttpClient httpClient = new(handler); | ||
|
|
||
| MapsClientOptions options = new() | ||
| { | ||
| Transport = new HttpClientPipelineTransport(httpClient) | ||
| }; | ||
| ``` | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,24 @@ | ||
|
|
||
| # System.ClientModel-based ModelReaderWriter samples | ||
|
|
||
| ## Read and write persistable models | ||
|
|
||
| Client library authors can implement the `IPersistableModel<T>` or `IJsonModel<T>` interfaces on strongly-typed model implementations. If they do, end-users of service clients can then read and write those models in cases where they need to persist them to a backing store. | ||
|
|
||
| The example below shows how to write a persistable model to `BinaryData`. | ||
|
|
||
| ```C# Snippet:Readme_Write_Simple | ||
| InputModel model = new InputModel(); | ||
| BinaryData data = ModelReaderWriter.Write(model); | ||
| ``` | ||
|
|
||
| The example below shows how to read JSON to create a strongly-typed model instance. | ||
|
|
||
| ```C# Snippet:Readme_Read_Simple | ||
| string json = @"{ | ||
| ""x"": 1, | ||
| ""y"": 2, | ||
| ""z"": 3 | ||
| }"; | ||
| OutputModel? model = ModelReaderWriter.Read<OutputModel>(BinaryData.FromString(json)); | ||
| ``` |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,14 @@ | ||
| --- | ||
| page_type: sample | ||
| languages: | ||
| - csharp | ||
| products: | ||
| - dotnet-core | ||
| name: System.ClientModel samples for .NET | ||
| description: Samples for the System.ClientModel library | ||
| --- | ||
|
|
||
| # System.ClientModel Samples | ||
|
|
||
| - [Client Configuration](https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/core/System.ClientModel/samples/Configuration.md) | ||
| - [Service Methods](https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/core/System.ClientModel/samples/ServiceMethods.md) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,112 @@ | ||
| # System.ClientModel-based client service methods | ||
|
|
||
| ## Introduction | ||
|
|
||
| `System.ClientModel`-based clients, or **service clients**, provide an interface to cloud services by translating library calls to HTTP requests. | ||
|
|
||
| In service clients, there are two ways to expose the schematized body in the request or response, known as the **message body**: | ||
|
|
||
| - **Convenience methods** take strongly-typed models as parameters. These models are C# classes which map to the message body of the REST call. | ||
|
|
||
| - **Protocol method** take primitive types as parameters and their `BinaryContent` input parameters mirror the message body directly. Protocol methods provide more direct access to the HTTP API protocol used by the service. | ||
|
|
||
| ## Convenience methods | ||
|
|
||
| **Convenience methods** provide a convenient way to invoke a service operation. They are service methods that take a strongly-typed model representing schematized data sent to the service as input, and return a strongly-typed model representing the payload from the service response as output. Having strongly-typed models that represent service concepts provides a layer of convenience over working with the raw payload format. This is because these models unify the client user experience when cloud services differ in payload formats. That is, a client-user can learn the patterns for strongly-typed models that `System.ClientModel`-based clients provide, and use them together without having to reason about whether a cloud service represents resources using, for example, JSON or XML formats. | ||
|
|
||
| The following sample illustrates how to call a convenience method and access both the strongly-typed output model and the details of the HTTP response. | ||
|
|
||
| ```C# Snippet:ClientResultTReadme | ||
| // Create a client | ||
| string? key = Environment.GetEnvironmentVariable("MAPS_API_KEY"); | ||
| ApiKeyCredential credential = new(key!); | ||
| MapsClient client = new(new Uri("https://atlas.microsoft.com"), credential); | ||
|
|
||
| // Call a service method, which returns ClientResult<T> | ||
| IPAddress ipAddress = IPAddress.Parse("2001:4898:80e8:b::189"); | ||
| ClientResult<IPAddressCountryPair> result = await client.GetCountryCodeAsync(ipAddress); | ||
|
|
||
| // ClientResult<T> has two members: | ||
| // | ||
| // (1) A Value property to access the strongly-typed output | ||
| IPAddressCountryPair value = result.Value; | ||
| Console.WriteLine($"Country is {value.CountryRegion.IsoCode}."); | ||
|
|
||
| // (2) A GetRawResponse method for accessing the details of the HTTP response | ||
| PipelineResponse response = result.GetRawResponse(); | ||
|
|
||
| Console.WriteLine($"Response status code: '{response.Status}'."); | ||
| Console.WriteLine("Response headers:"); | ||
| foreach (KeyValuePair<string, string> header in response.Headers) | ||
| { | ||
| Console.WriteLine($"Name: '{header.Key}', Value: '{header.Value}'."); | ||
| } | ||
| ``` | ||
|
|
||
| ## Protocol methods | ||
|
|
||
| In contrast to convenience methods, **protocol methods** are service methods that provide very little convenience over the raw HTTP APIs a cloud service exposes. They represent request and response message bodies using types that are very thin layers over raw JSON/binary/other formats. Users of client protocol methods must reference a service's API documentation directly, rather than relying on the client to provide developer conveniences via strongly-typing service schemas. | ||
|
|
||
| The following sample illustrates how to call a protocol method, including creating the request payload and accessing the details of the HTTP response. | ||
|
|
||
| ```C# Snippet:ServiceMethodsProtocolMethod | ||
| // Create a BinaryData instance from a JSON string literal. | ||
| BinaryData input = BinaryData.FromString(""" | ||
| { | ||
| "countryRegion": { | ||
| "isoCode": "US" | ||
| }, | ||
| } | ||
| """); | ||
|
|
||
| // Create a BinaryContent instance to set as the HTTP request content. | ||
| BinaryContent requestContent = BinaryContent.Create(input); | ||
|
|
||
| // Call the protocol method | ||
| ClientResult result = await client.AddCountryCodeAsync(requestContent); | ||
|
|
||
| // Obtain the output response content from the returned ClientResult. | ||
| BinaryData output = result.GetRawResponse().Content; | ||
|
|
||
| using JsonDocument outputAsJson = JsonDocument.Parse(output.ToString()); | ||
| string isoCode = outputAsJson.RootElement | ||
| .GetProperty("countryRegion") | ||
| .GetProperty("isoCode") | ||
| .GetString(); | ||
|
|
||
| Console.WriteLine($"Code for added country is '{isoCode}'."); | ||
| ``` | ||
|
|
||
| Protocol methods take an optional `RequestOptions` parameter. `RequestOptions` can be used to modify various aspects of the HTTP request sent by the service method, such as adding a request header, or adding a policy to the client pipeline that can modify the request directly before sending it to the service. `RequestOptions` also enables passing a `CancellationToken` to the method. | ||
|
|
||
| ```C# Snippet:RequestOptionsReadme | ||
| // Create RequestOptions instance | ||
| RequestOptions options = new(); | ||
|
|
||
| // Set CancellationToken | ||
| options.CancellationToken = cancellationToken; | ||
|
|
||
| // Add a header to the request | ||
| options.AddHeader("CustomHeader", "CustomHeaderValue"); | ||
|
|
||
| // Call protocol method to pass RequestOptions | ||
| ClientResult output = await client.GetCountryCodeAsync(ipAddress.ToString(), options); | ||
| ``` | ||
|
|
||
annelo-msft marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
| ## Handling exceptions | ||
|
|
||
| When a service call fails, service clients throw a `ClientResultException`. The exception exposes the HTTP status code and the details of the service response if available. | ||
|
|
||
| ```C# Snippet:ClientResultExceptionReadme | ||
| try | ||
| { | ||
| IPAddress ipAddress = IPAddress.Parse("2001:4898:80e8:b::189"); | ||
| ClientResult<IPAddressCountryPair> result = await client.GetCountryCodeAsync(ipAddress); | ||
| } | ||
| // Handle exception with status code 404 | ||
| catch (ClientResultException e) when (e.Status == 404) | ||
| { | ||
| // Handle not found error | ||
| Console.Error.WriteLine($"Error: Response failed with status code: '{e.Status}'"); | ||
| } | ||
| ``` | ||
119 changes: 119 additions & 0 deletions
119
sdk/core/System.ClientModel/tests/Samples/ConfigurationSamples.cs
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,119 @@ | ||
| // Copyright (c) Microsoft Corporation. All rights reserved. | ||
| // Licensed under the MIT License. | ||
|
|
||
| using System.ClientModel.Primitives; | ||
| using System.Collections.Generic; | ||
| using System.Diagnostics; | ||
| using System.Net.Http; | ||
| using System.Threading.Tasks; | ||
| using Maps; | ||
| using NUnit.Framework; | ||
|
|
||
| namespace System.ClientModel.Tests.Samples; | ||
|
|
||
| public class ConfigurationSamples | ||
| { | ||
| [Test] | ||
| [Ignore("Used for README")] | ||
| public void ClientModelConfigurationReadme() | ||
| { | ||
| #region Snippet:ClientModelConfigurationReadme | ||
|
|
||
| MapsClientOptions options = new() | ||
| { | ||
| NetworkTimeout = TimeSpan.FromSeconds(120), | ||
| }; | ||
|
|
||
| string? key = Environment.GetEnvironmentVariable("MAPS_API_KEY"); | ||
| ApiKeyCredential credential = new(key!); | ||
| MapsClient client = new(new Uri("https://atlas.microsoft.com"), credential, options); | ||
|
|
||
| #endregion | ||
| } | ||
|
|
||
| [Test] | ||
| [Ignore("Used for README")] | ||
| public void ConfigurationCustomizeRetries() | ||
| { | ||
| #region Snippet:ConfigurationCustomizeRetries | ||
|
|
||
| MapsClientOptions options = new() | ||
| { | ||
| RetryPolicy = new ClientRetryPolicy(maxRetries: 5), | ||
| }; | ||
|
|
||
| string? key = Environment.GetEnvironmentVariable("MAPS_API_KEY"); | ||
| ApiKeyCredential credential = new(key!); | ||
| MapsClient client = new(new Uri("https://atlas.microsoft.com"), credential, options); | ||
|
|
||
| #endregion | ||
| } | ||
|
|
||
| [Test] | ||
| public void ConfigurationAddPolicies() | ||
| { | ||
| #region Snippet:ConfigurationAddPerCallPolicy | ||
| MapsClientOptions options = new(); | ||
| options.AddPolicy(new StopwatchPolicy(), PipelinePosition.PerCall); | ||
| #endregion | ||
|
|
||
| #region Snippet:ConfigurationAddPerTryPolicy | ||
| options.AddPolicy(new StopwatchPolicy(), PipelinePosition.PerTry); | ||
| #endregion | ||
|
|
||
| #region Snippet:ConfigurationAddBeforeTransportPolicy | ||
| options.AddPolicy(new StopwatchPolicy(), PipelinePosition.BeforeTransport); | ||
| #endregion | ||
| } | ||
|
|
||
| #region Snippet:ConfigurationCustomPolicy | ||
| public class StopwatchPolicy : PipelinePolicy | ||
| { | ||
| public override async ValueTask ProcessAsync(PipelineMessage message, IReadOnlyList<PipelinePolicy> pipeline, int currentIndex) | ||
| { | ||
| Stopwatch stopwatch = new(); | ||
| stopwatch.Start(); | ||
|
|
||
| await ProcessNextAsync(message, pipeline, currentIndex); | ||
|
|
||
| stopwatch.Stop(); | ||
|
|
||
| Console.WriteLine($"Request to {message.Request.Uri} took {stopwatch.Elapsed}"); | ||
| } | ||
|
|
||
| public override void Process(PipelineMessage message, IReadOnlyList<PipelinePolicy> pipeline, int currentIndex) | ||
| { | ||
| Stopwatch stopwatch = new(); | ||
| stopwatch.Start(); | ||
|
|
||
| ProcessNext(message, pipeline, currentIndex); | ||
|
|
||
| stopwatch.Stop(); | ||
|
|
||
| Console.WriteLine($"Request to {message.Request.Uri} took {stopwatch.Elapsed}"); | ||
| } | ||
| } | ||
| #endregion | ||
|
|
||
| [Test] | ||
| public void ConfigurationCustomHttpClient() | ||
| { | ||
| #region Snippet:ConfigurationCustomHttpClient | ||
| using HttpClientHandler handler = new() | ||
| { | ||
| // Reduce the max connections per server, which defaults to 50. | ||
| MaxConnectionsPerServer = 25, | ||
|
|
||
| // Preserve default System.ClientModel redirect behavior. | ||
| AllowAutoRedirect = false, | ||
| }; | ||
|
|
||
| using HttpClient httpClient = new(handler); | ||
|
|
||
| MapsClientOptions options = new() | ||
| { | ||
| Transport = new HttpClientPipelineTransport(httpClient) | ||
| }; | ||
| #endregion | ||
| } | ||
| } |
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Uh oh!
There was an error while loading. Please reload this page.