Client configuration #4
There are no files selected for viewing
This file contains 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,84 @@ | ||
| // Copyright (c) Microsoft Corporation. All rights reserved. | ||
| // Licensed under the MIT License. | ||
|
|
||
| using System; | ||
| using System.Text.Json; | ||
| using System.Threading; | ||
| using System.Threading.Tasks; | ||
| using Azure.Core; | ||
| using Azure.Core.Pipeline; | ||
|
|
||
| namespace Azure.AI.Personalizer.Models | ||
| { | ||
| internal class ClientConfigurationRestClient | ||
| { | ||
| private string endpoint; | ||
| private ClientDiagnostics _clientDiagnostics; | ||
| private HttpPipeline _pipeline; | ||
|
|
||
| /// <summary> Initializes a new instance of ClientConfigurationRestClient. </summary> | ||
| /// <param name="clientDiagnostics"> The handler for diagnostic messaging in the client. </param> | ||
| /// <param name="pipeline"> The HTTP pipeline for sending and receiving REST requests and responses. </param> | ||
| /// <param name="endpoint"> Supported Cognitive Services endpoint. </param> | ||
| /// <exception cref="ArgumentNullException"> <paramref name="endpoint"/> is null. </exception> | ||
| public ClientConfigurationRestClient(ClientDiagnostics clientDiagnostics, HttpPipeline pipeline, string endpoint) | ||
| { | ||
| this.endpoint = endpoint ?? throw new ArgumentNullException(nameof(endpoint)); | ||
| _clientDiagnostics = clientDiagnostics; | ||
| _pipeline = pipeline; | ||
| } | ||
| internal HttpMessage CreatePostRequest() | ||
| { | ||
| var message = _pipeline.CreateMessage(); | ||
| var request = message.Request; | ||
| request.Method = RequestMethod.Post; | ||
| var uri = new RawRequestUriBuilder(); | ||
| uri.AppendRaw(endpoint, false); | ||
| uri.AppendRaw("/personalizer/v1.1-preview.1", false); | ||
| uri.AppendPath("/configurations/client", false); | ||
| request.Uri = uri; | ||
| request.Headers.Add("Accept", "application/json"); | ||
| return message; | ||
| } | ||
|
|
||
| /// <summary> Get the Personalizer service configuration. </summary> | ||
| /// <param name="cancellationToken"> The cancellation token to use. </param> | ||
| public async Task<Response<PersonalizerClientProperties>> PostAsync(CancellationToken cancellationToken = default) | ||
| { | ||
| using var message = CreatePostRequest(); | ||
| await _pipeline.SendAsync(message, cancellationToken).ConfigureAwait(false); | ||
| switch (message.Response.Status) | ||
| { | ||
| case 200: | ||
| { | ||
| PersonalizerClientProperties value = default; | ||
| using var document = await JsonDocument.ParseAsync(message.Response.ContentStream, default, cancellationToken).ConfigureAwait(false); | ||
| value = PersonalizerClientProperties.DeserializePersonalizerServiceProperties(document.RootElement); | ||
| return Response.FromValue(value, message.Response); | ||
| } | ||
| default: | ||
| throw await _clientDiagnostics.CreateRequestFailedExceptionAsync(message.Response).ConfigureAwait(false); | ||
| } | ||
| } | ||
|
|
||
| /// <summary> Get the Personalizer service configuration. </summary> | ||
| /// <param name="cancellationToken"> The cancellation token to use. </param> | ||
| public Response<PersonalizerClientProperties> Post(CancellationToken cancellationToken = default) | ||
| { | ||
| using var message = CreatePostRequest(); | ||
| _pipeline.Send(message, cancellationToken); | ||
| switch (message.Response.Status) | ||
| { | ||
| case 200: | ||
| { | ||
| PersonalizerClientProperties value = default; | ||
| using var document = JsonDocument.Parse(message.Response.ContentStream); | ||
| value = PersonalizerClientProperties.DeserializePersonalizerServiceProperties(document.RootElement); | ||
| return Response.FromValue(value, message.Response); | ||
| } | ||
| default: | ||
| throw _clientDiagnostics.CreateRequestFailedException(message.Response); | ||
| } | ||
| } | ||
| } | ||
| } | ||
This file contains 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
This file contains 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,50 @@ | ||
| // Copyright (c) Microsoft Corporation. All rights reserved. | ||
| // Licensed under the MIT License. | ||
|
|
||
| using System; | ||
| using System.Text.Json; | ||
| using Azure.Core; | ||
|
|
||
| namespace Azure.AI.Personalizer.Models | ||
| { | ||
| internal partial class PersonalizerClientProperties | ||
| { | ||
| internal static PersonalizerClientProperties DeserializePersonalizerServiceProperties(JsonElement element) | ||
|
There was a problem hiding this comment. Can you explain why we need a custom deserializer instead of using |
||
| { | ||
| string applicationID = default; | ||
| string modelBlobUri = default; | ||
| float initialExplorationEpsilon = default; | ||
| PersonalizerLearningMode learningMode = default; | ||
| string initialCommandLine = default; | ||
| foreach (var property in element.EnumerateObject()) | ||
| { | ||
| if (property.NameEquals("applicationID")) | ||
| { | ||
| applicationID = property.Value.GetString(); | ||
| continue; | ||
| } | ||
| if (property.NameEquals("modelBlobUri")) | ||
| { | ||
| modelBlobUri = property.Value.GetString(); | ||
| continue; | ||
| } | ||
| if (property.NameEquals("initialExplorationEpsilon")) | ||
| { | ||
| initialExplorationEpsilon = property.Value.GetSingle(); | ||
| continue; | ||
| } | ||
| if (property.NameEquals("learningMode")) | ||
| { | ||
| learningMode = new PersonalizerLearningMode(property.Value.GetString()); | ||
| continue; | ||
| } | ||
| if (property.NameEquals("initialCommandLine")) | ||
| { | ||
| initialCommandLine = property.Value.GetString(); | ||
| continue; | ||
| } | ||
| } | ||
| return new PersonalizerClientProperties(applicationID, modelBlobUri, initialExplorationEpsilon, learningMode, initialCommandLine); | ||
| } | ||
| } | ||
| } | ||
This file contains 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,60 @@ | ||
| // Copyright (c) Microsoft Corporation. All rights reserved. | ||
| // Licensed under the MIT License. | ||
|
|
||
| using System; | ||
| using System.Collections.Generic; | ||
| using System.Text; | ||
|
|
||
| namespace Azure.AI.Personalizer.Models | ||
| { | ||
| internal partial class PersonalizerClientProperties | ||
| { | ||
| internal PersonalizerClientProperties(string applicationID, string modelBlobUri, float initialExplorationEpsilon, PersonalizerLearningMode learningMode, string initialCommandLine) | ||
| { | ||
| ApplicationID = applicationID; | ||
| ModelBlobUri = modelBlobUri; | ||
| InitialExplorationEpsilon = initialExplorationEpsilon; | ||
| LearningMode = learningMode; | ||
| InitialCommandLine = initialCommandLine; | ||
| } | ||
| /// <summary> | ||
| /// Unique identifier for this Personalizer instance. | ||
| /// </summary> | ||
| public string ApplicationID { get; } | ||
|
|
||
| /// <summary> | ||
| /// Event hub connection string for sending interactions. | ||
| /// </summary> | ||
| public string EventHubInteractionConnectionString { get;} | ||
|
|
||
| /// <summary> | ||
| /// Event hub connection string for sending observations. | ||
| /// </summary> | ||
| public string EventHubObservationConnectionString { get; } | ||
|
|
||
| /// <summary> | ||
| /// SAS Uri for the inference model. | ||
| /// </summary> | ||
| public string ModelBlobUri { get; } | ||
|
|
||
| /// <summary> | ||
| /// Exploration value used before downloading model in CB. | ||
| /// </summary> | ||
| public float InitialExplorationEpsilon { get; } | ||
|
|
||
| /// <summary> | ||
| /// Learning Mode setting. | ||
| /// </summary> | ||
| public PersonalizerLearningMode LearningMode { get; } | ||
|
|
||
| /// <summary> | ||
| /// Command line used for prediction before downloading model. | ||
| /// </summary> | ||
| public string InitialCommandLine { get; } | ||
|
|
||
| /// <summary> | ||
| /// Version used by reinforcement learning client. | ||
| /// </summary> | ||
| public int ProtocolVersion { get; } | ||
| } | ||
| } |
This file contains 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
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.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why isn't this class in the generated folder? Rest clients should not be hand written, only extended.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
As client Post is not part of swagger because of which it's not part of generated. So implemented it outside generated to get client config details