Introduction
In the great blog by Kiril Receive Notifications for Failed SAP Cloud Platform Integration Flows via Any Channel with Alert Not... you could learn how to send notifications for failed iFlows from CPI to SAP ANS. It helped me a lot in my development and implementation however I faced some problems due to lack of flexibility when it comes to notification payload. I managed to work it out however and in this blog I'll show you how.
I'll describe how you can change the standard SAP iFlow in a way it'll send more information to ANS. I'll also present how you can run more than one at the same time and tell the difference between them in ANS.
The iFlow
As described in the blog by Kiril the standard iFlow you will be using is "Send notifications for failed Message Processing LogsMessage" from the SAP package "SAP Cloud Platform Integration with SAP Cloud Platform Alert Notification".
In order to be able to modify it you will need to create a new package and copy it there. In my case it looks like this:
So far so good! Now let's take a look how it works. We'll be interested in two parts of the flow.
1. OData adapter
When you look at the configuration you'll notice that Query Options narrows down the query to IntegrationArtifact node. We don't want that!
Look at the example (taken from SAP API Business Hub):
{
"MessageGuid": "AFq478Bblxi4wCjBcDb_G0vAGGZG",
"CorrelationId": "AFq478Bmn-aPieAWVy0mMGPLWsjx",
"ApplicationMessageId": 0000000123,
"ApplicationMessageType": null,
"LogStart": "/Date(1522069440003)/",
"LogEnd": "/Date(1522069440200)/",
"Sender": null,
"Receiver": null,
"IntegrationFlowName": "IntegrationFlow_AdapterData_FAILED_PROCESSING",
"Status": "FAILED",
"AlternateWebLink": "https://sandbox.api.sap.com:443:443/itspaces/shell/monitoring/MessageDetails/%7B%22messageGuid%22%3A%22AFq478Bblxi4wCjBcDb_G0vAGGZG%22%7D",
"IntegrationArtifact": {
"Id": "IntegrationFlow_AdapterData_FAILED_PROCESSING",
"Name": "Integration Flow with Adapter Data - FAILED PROCESSING",
"Type": "INTEGRATION_FLOW"
},
"LogLevel": "INFO",
"CustomStatus": "FAILED",
"TransactionId": "636260297acc487198a65955d3648c49",
"PreviousComponentName": "CPI_cpisbsa1",
"LocalComponentName": "CPI_cpisbsa1",
"OriginComponentName": null,
"CustomHeaderProperties": {
"__deferred": {
"uri": "https://sandbox.api.sap.com:443:443/cpi/api/v1/MessageProcessingLogs('AFq478Bblxi4wCjBcDb_G0vAGGZG')/CustomHeaderProperties"
}
},
"MessageStoreEntries": {
"__deferred": {
"uri": "https://sandbox.api.sap.com:443:443/cpi/api/v1/MessageProcessingLogs('AFq478Bblxi4wCjBcDb_G0vAGGZG')/MessageStoreEntries"
}
},
"ErrorInformation": {
"__deferred": {
"uri": "https://sandbox.api.sap.com:443:443/cpi/api/v1/MessageProcessingLogs('AFq478Bblxi4wCjBcDb_G0vAGGZG')/ErrorInformation"
}
},
"AdapterAttributes": {
"__deferred": {
"uri": "https://sandbox.api.sap.com:443:443/cpi/api/v1/MessageProcessingLogs('AFq478Bblxi4wCjBcDb_G0vAGGZG')/AdapterAttributes"
}
},
"Attachments": {
"__deferred": {
"uri": "https://sandbox.api.sap.com:443:443/cpi/api/v1/MessageProcessingLogs('AFq478Bblxi4wCjBcDb_G0vAGGZG')/Attachments"
}
},
"Runs": {
"__deferred": {
"uri": "https://sandbox.api.sap.com:443:443/cpi/api/v1/MessageProcessingLogs('AFq478Bblxi4wCjBcDb_G0vAGGZG')/Runs"
}
}
}If we narrowed it down only to "IntegrationArtifact" we would loose quite a bit of details. My requirement was to present MessageGuids and ApplicationMessageIds as these were idoc numbers pretty relevant for identifying the issue.
In a summary - remove
&$select=IntegrationArtifactfrom the query (if you need these details, I did).
2. Map Message Process Logs to Service Notifications
The second part is more interesting - we'll need to groovy a little bit. The above script is responsible for sending the notification to ANS service. We would like to modify it a little bit. The below is my proposition:
Event toNotification(String flowId, def messages, Message message) {
String flowName = messages[0].IntegrationArtifact.Name.toString()
String flowType = messages[0].IntegrationArtifact.Type.toString()
String currentTimeFrameStart = getStringHeader(message, CURRENT_TIME_FRAME_START_HEADER_NAME)
String currentTimeFrameEnd = getStringHeader(message, CURRENT_TIME_FRAME_END_HEADER_NAME)
//Added --------------
//The flow sends aggregated results therefore all failed guids/idocs will need to be aggregated as well
StringBuilder applicationMessageIds = new StringBuilder("")
//Loop through messages and get the details
for(mess in messages) {
if(mess.ApplicationMessageId.toString()){
applicationMessageIds.append(";" + mess.ApplicationMessageId.toString())
} else {
applicationMessageIds.append(";" + mess.MessageGuid.toString())
}
}
//Added --------------
return new Event(
//You can modify eventType too!
eventType: "CPIIntegrationFlowExecutionFailure",
resource: new Resource(
resourceName: flowName,
resourceType: flowType
),
severity: "INFO",
category: "NOTIFICATION",
subject: "CPI Integration Flow '${flowName}': Execution Failure",
body: "There were '${messages.size()}' failures for the '${flowName}' integration flow within the time frame starting from '${currentTimeFrameStart}' and ending at '${currentTimeFrameEnd}'. ",
tags: [
'cpi:IntegrationArtifact.Id': flowId,
//Added --------
'Details': applicationMessageIds.toString()
//Added --------
]
)
}With the above sneaky move we can send the exact messages that failed to ANS. You can add as many tags as you want, this was the best place and way to send more information than standard SAP flow allowed me to. I also tried to be smart and change class Event:
class Event {
String eventType
Resource resource
String severity
String category
String subject
String body
Map tags
}But ANS failed at this point so I would suggest operating only on tags.
Parallel ANS iFlows
If you were cautious you noticed in the coding above that modifying eventType is also allowed. With such flexibility you could run more than one with different eventType to be able to differentiate them in ANS. In my case it was a different severenity of raised incidents in a webhook across day and night. Therefore I created two flows, one for night and one for day with different eventTypes and in ANS I was able to tell what severity I want (it was supposed to be lower at night).
Alert Notification Service
On the ANS side when notifications are received you can get new nodes exactly as you would with standard ones. In my case:
{tags.Details}Summary
In the above blog I described a way to modify the standard SAP iFlow to send notifications to ANS. As you have already noticed if you dig deep enough you can extract pretty much information from CPI.
What I described is only a proposition what can be achieved. I'm sure you will be able to figure out a solution tailored to your needs with some research and grooving. I hope the above post will give you a good starting point to do so.
- SAP Managed Tags:
3 Comments
