Update CosmosDB Samples #141
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
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,9 @@ | ||
| using System.Collections.Generic; | ||
|
|
||
| namespace Microsoft.Azure.WebJobs.Extensions.Redis.Samples.CosmosDB.Models | ||
| { | ||
| public record CosmosDBListData( | ||
| string id, | ||
| List<string> value | ||
| ); | ||
| } | ||
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,11 @@ | ||
| using System; | ||
|
|
||
| namespace Microsoft.Azure.WebJobs.Extensions.Redis.Samples.CosmosDB.Models | ||
| { | ||
| public record PubSubData( | ||
| string id, | ||
| string channel, | ||
| string message, | ||
| DateTime timestamp | ||
| ); | ||
| } |
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,11 @@ | ||
| using System; | ||
|
|
||
| namespace Microsoft.Azure.WebJobs.Extensions.Redis.Samples.CosmosDB.Models | ||
| { | ||
| public record RedisData( | ||
| string id, | ||
| string key, | ||
| string value, | ||
| DateTime timestamp | ||
| ); | ||
| } |
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,25 @@ | ||
| using Microsoft.Extensions.Logging; | ||
| using StackExchange.Redis; | ||
| using System.Collections.Generic; | ||
| using System.Linq; | ||
|
|
||
| namespace Microsoft.Azure.WebJobs.Extensions.Redis.Samples.CosmosDB.Models | ||
| { | ||
| public class StreamData | ||
|
There was a problem hiding this comment. Why is this not a |
||
| { | ||
| public string id { get; set; } | ||
| public Dictionary<string, string> values { get; set; } | ||
|
|
||
| // Helper method to format stream message | ||
| public static StreamData Format(StreamEntry entry, ILogger logger) | ||
| { | ||
| logger.LogInformation("ID: {val}", entry.Id.ToString()); | ||
|
There was a problem hiding this comment. Why are we logging in a |
||
|
|
||
| // Map each key value pair | ||
| Dictionary<string, string> dict = entry.Values.ToDictionary(value => value.Name.ToString(), value => value.Value.ToString()); | ||
|
|
||
| StreamData sampleItem = new StreamData { id = entry.Id, values = dict }; | ||
| return sampleItem; | ||
| } | ||
| } | ||
| } | ||
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,51 @@ | ||
| using Microsoft.Extensions.Logging; | ||
| using StackExchange.Redis; | ||
| using System.Collections.Generic; | ||
| using System.Linq; | ||
|
|
||
| namespace Microsoft.Azure.WebJobs.Extensions.Redis.Samples.CosmosDB.Models | ||
| { | ||
| public class StreamDataSingleDocument | ||
| { | ||
| public string id { get; set; } | ||
| public int maxlen { get; set; } | ||
| public Dictionary<string, Dictionary<string, string>> messages { get; set; } | ||
|
|
||
| public static StreamDataSingleDocument CreateNewEntry(StreamEntry entry, string streamName, ILogger logger) | ||
| { | ||
| logger.LogInformation("Creating a new document for {val}. Inserting ID: {val} as the first entry", streamName, entry.Id.ToString()); | ||
|
|
||
| // Map each key value pair | ||
| Dictionary<string, string> dict = entry.Values.ToDictionary(value => value.Name.ToString(), value => value.Value.ToString()); | ||
|
|
||
| // Create a new list of messages | ||
| var list = new Dictionary<string, Dictionary<string, string>>(); | ||
|
There was a problem hiding this comment. Can simplify to |
||
| list.Add(entry.Id.ToString(), dict); | ||
|
|
||
| StreamDataSingleDocument data = new StreamDataSingleDocument { id = streamName, maxlen = 1000, messages = list }; | ||
| return data; | ||
| } | ||
|
|
||
| public static StreamDataSingleDocument UpdateExistingEntry(StreamDataSingleDocument results, StreamEntry entry, ILogger logger) | ||
| { | ||
| logger.LogInformation("Adding to {val} document. Inserting ID: {val} ", results.id, entry.Id.ToString()); | ||
|
|
||
| // Map each key value pair | ||
| Dictionary<string, string> dict = entry.Values.ToDictionary(value => value.Name.ToString(), value => value.Value.ToString()); | ||
|
|
||
| // Update list of messages | ||
| var list = results.messages; | ||
| list.Add(entry.Id.ToString(), dict); | ||
|
|
||
| if (list.Count > results.maxlen) | ||
| { | ||
| string minKey = list.Keys.Min(); | ||
| list.Remove(minKey); | ||
| } | ||
|
|
||
| StreamDataSingleDocument data = new StreamDataSingleDocument { id = results.id, maxlen = results.maxlen, messages = list }; | ||
|
|
||
| return data; | ||
| } | ||
|
|
||
| } | ||
| } | ||
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
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.
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.
These should ideally start with capital letters by convention. This applies to all the models