Advertisement
ariswb22

[Query] Titanium Jobs

Jul 1st, 2021 (edited)
2,511
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
SQL 2.86 KB | None | 0 0
  1. --Titanium
  2. SELECT
  3.     TOP 10
  4.     CONVERT(VARCHAR, ReportingDate, 107) AS ReportingDate,
  5.     JSON_VALUE(DATA, '$.extractor.source') AS Sources,
  6.     FORMAT(CAST(JSON_VALUE(DATA, '$.extractor.rowsLoaded') AS INT), '#,0') AS RowsLoaded,
  7.     --array 0
  8.     FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.gobbler.processed') AS INT), '#,0') AS "Gobbler[1]",
  9.     FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.sinker.processed') AS DECIMAL(18,2)) / CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.gobbler.processed') AS DECIMAL(18,2)),'P') AS "Process[1]",
  10.     CONCAT(
  11.         'Qualigator [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.qualigator.processed') AS INT), '#,0'), '], ',
  12.         'Sinker [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.sinker.processed') AS INT), '#,0'), '], ',
  13.         'Final [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.finalTracking.processed') AS INT), '#,0'), ']'
  14.     ) AS "Processed[1]",
  15.     CONCAT(
  16.         'Qualigator [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.qualigator.rejected') AS INT), '#,0'), '], ',
  17.         'Sinker [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.sinker.rejected') AS INT), '#,0'), '], ',
  18.         'Final [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.finalTracking.rejected') AS INT), '#,0'), ']'
  19.     ) AS "Rejected[1]",
  20.     --array 1
  21.     FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.gobbler.processed') AS INT), '#,0') AS "Gobbler[2]",
  22.     FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.sinker.processed') AS DECIMAL(18,2)) / CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.gobbler.processed') AS DECIMAL(18,2)),'P') AS "Process[2]",
  23.     CONCAT(
  24.         'Qualigator [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.qualigator.processed') AS INT), '#,0'), '], ',
  25.         'Sinker [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.sinker.processed') AS INT), '#,0'), '], ',
  26.         'Final [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.finalTracking.processed') AS INT), '#,0'), ']'
  27.     ) AS "Processed[2]",
  28.     CONCAT(
  29.         'Qualigator [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.qualigator.rejected') AS INT), '#,0'), '], ',
  30.         'Sinker [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.sinker.rejected') AS INT), '#,0'), '], ',
  31.         'Final [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.finalTracking.rejected') AS INT), '#,0'), ']'
  32.     ) AS "Rejected[2]",
  33.     CONVERT(VARCHAR, DATEADD(HOUR, 7, StartTimestamp), 0) AS START,
  34.     CONVERT(VARCHAR, DATEADD(HOUR, 7, CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.sinker.lastContactTimestamp') AS DATETIME2)), 0) AS Finish,
  35.     DATEDIFF(mi, CAST(StartTimestamp AS DATETIME2), CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.sinker.lastContactTimestamp') AS DATETIME2)) AS "Duration[min]"
  36. FROM Titanium..Jobs
  37.     ORDER BY StartTimestamp DESC;
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement