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
traces | |
| where operation_Name == "FlowRunLastJob" | |
| extend resource = parse_json(tostring(parse_json(tostring(customDimensions.prop__properties)).resource)) | |
| extend error = parse_json(tostring(customDimensions.prop__error)) | |
| project timestamp | |
, LogicApp = tostring(cloud_RoleName) | |
, Workflow = tostring(resource.workflowName) | |
, WorkflowRunId = tostring(customDimensions.prop__flowRunSequenceId) | |
, ClientTrackingId = tostring(customDimensions.prop__clientTrackingId) | |
, WorkflowStatus = customDimensions.prop__status |
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
// Error Count grouped by InterfaceId and trace event type (EventName) | |
traces | |
| sort by timestamp desc | |
| where customDimensions.prop__Status == "Failed" | |
| where customDimensions.EventName != "" | |
| where tostring(customDimensions.prop__InterfaceId) != "" | |
| project EventName = tostring(customDimensions.EventName) | |
, InterfaceId = tostring(customDimensions.prop__InterfaceId) | |
| summarize Count = count(EventName) | |
by InterfaceId |
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
// Message Count per EntityType and time bin | |
traces | |
| sort by timestamp desc | |
| where customDimensions.EventName != "" | |
| where tostring(customDimensions.prop__SpanCheckpointId) contains "PublisherStart" | |
| project timestamp | |
, EntityType = tostring(customDimensions.prop__EntityType) | |
| summarize Count = count(EntityType) | |
by bin(timestamp, 1h), | |
EntityType |
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
// Traces with failed status | |
// Traces can be filtered uncommenting the filters at the bottom and adding the corresponding filter values | |
traces | |
| sort by timestamp desc | |
| where customDimensions.prop__Status == "Failed" | |
| project | |
timestamp | |
, InterfaceId = customDimensions.prop__InterfaceId | |
, EntityType = customDimensions.prop__EntityType | |
, EntityId = customDimensions.prop__EntityId |
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
// All trace events related to the 'BatchPublisher' span | |
// Correlates the Start and Finish checkpoints and returns the relevant key-value pairs | |
// Traces can be filtered uncommenting the filters at the bottom and adding the corresponding filter values | |
traces | |
| sort by timestamp desc | |
| where customDimensions.prop__SpanCheckpointId == 'BatchPublisherStart' | |
| project BatchPublisherStart = timestamp | |
, BatchPublisherStartLevel = customDimensions.LogLevel | |
, InterfaceId = customDimensions.prop__InterfaceId | |
, EntityType = customDimensions.prop__EntityType |
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
### Variables | |
@functionHost=https://<function-app-name>.azurewebsites.net | |
### | |
POST {{functionHost}}/userupdated | |
Content-Type: application/json | |
{ | |
"specversion" : "1.0", | |
"type" : "user.updated", |
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
using Integration.Observability.Constants; | |
using Integration.Observability.Extensions; | |
using Integration.Observability.Helpers; | |
using Integration.Observability.PubSub.FnApp.Models; | |
using Microsoft.Azure.ServiceBus; | |
using Microsoft.Azure.ServiceBus.Core; | |
using Microsoft.Azure.WebJobs; | |
using Microsoft.Extensions.Logging; | |
using Microsoft.Extensions.Options; | |
using System; |
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
using Integration.Observability.Constants; | |
using Integration.Observability.Extensions; | |
using Integration.Observability.Helpers; | |
using Integration.Observability.PubSub.FnApp.Models; | |
using Microsoft.AspNetCore.Http; | |
using Microsoft.AspNetCore.Mvc; | |
using Microsoft.Azure.ServiceBus; | |
using Microsoft.Azure.WebJobs; | |
using Microsoft.Azure.WebJobs.Extensions.Http; | |
using Microsoft.Extensions.Logging; |
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
using Integration.Observability.Constants; | |
using Microsoft.Extensions.Logging; | |
namespace Integration.Observability.Helpers | |
{ | |
public static class LoggerHelper | |
{ | |
/// <summary> | |
/// Calculate LogLevel based on the process status. | |
/// </summary> |