☰
Navigation :

Checking Transaction Status

How do I check status of a past request?

The DLC exposes an API to display the status of events based on the Processing ID (also called as Transaction ID and represented by “taskName” in the response). The transaction ID is normally returned as part of a load or an unload operation and is a hex string that looks like something like “7a8c982a87b050f2”. This API queries the internal cache for the provided transaction id and returns all the events/messages associated with it. The status endpoint is a REST GET request, see example below.

    REST URL: http://<hostname>:<port>/<app-context>/services/connectors/rest/dlc/v1/<rest-version>/status?processingId=<Processing ID>

Sample response

{
  "status": "success",
  "data": {
    "taskName": "7a8c982a87b050f2",
    "timeTakenMs": 454799,
    "events": [
      {
        "threadName": "csv-worker-csvSource-8",
        "threadId": 149,
        "clazz": "com.qfs.msg.csv.impl.PublicationQueue$1",
        "method": "onCompletion",
        "lineNumber": 159,
        "timeStamp": 1584031264779,
        "taskName": "LoadDataTxControllerTask-1",
        "level": {
          "name": "INFO",
          "resourceBundleName": "sun.util.logging.resources.logging",
          "localizedName": "INFO"
        },
        "upTime": 88493,
        "file": "C:\\source\\frtb-accelerator\\frtb-starter\\src\\test\\resources\\data\\2018-09-28\\Sensitivities\\config\\CSR_Bucket_Description_NONSEC.csv",
        "parsingInfo": {
          "publishedObjectCount": 18,
          "characterCount": 583,
          "lineCount": 19,
          "byteCount": 583,
          "elapsedTime": "PT0S",
          "aggregatedTime": 486899,
          "aggregatedReadingTime": 65100,
          "aggregatedDecodingTime": 21900,
          "aggregatedParsingTime": 35400,
          "aggregatedPublicationTime": 364499,
          "exceptions": [],
          "creationTime": "2020-03-12T16:41:04.779Z",
          "numberSkippedLines": 1
        },
        "fileLineNumber": 0,
        "tags": [
          "parsing",
          "csv",
          "source"
        ],
        "eventType": "LOAD_SUMMARY"
      },
      {
        "threadId": 0,
        "lineNumber": 0,
        "timeStamp": 1584031264779,
        "taskName": "7a8c982a87b050f2",
        "level": {
          "name": "INFO",
          "resourceBundleName": "sun.util.logging.resources.logging",
          "localizedName": "INFO"
        },
        "upTime": 0,
        "message": "[LOAD_SUMMARY][CSV_SOURCE] csvSource completed fetch batch csvSource-8 in 1542us ( 2 channels { StoreMessageChannel [topic=BookParentChild],StoreMessageChannel [topic=CSR_BUCKET_DESCRIPTION_NONSEC] } and scope {AsOfDate=2018-09-28} ). 2 KiB 859 bytes (2907) parsed into 73 lines (71 records published)).Average throughput: 1 MiB 817 KiB (1885214)/s, 47,341 lines parsed/s, 46,044 published records/s.",
        "tags": [
          "summary",
          "health",
          "dlc",
          "source"
        ],
        "eventType": "SUMMARY"
      }
    ],
    "dlcLoadingStatus": "SUCCEED"
  }
}
search.js