Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- --Titanium
- SELECT
- TOP 10
- CONVERT(VARCHAR, ReportingDate, 107) AS ReportingDate,
- JSON_VALUE(DATA, '$.extractor.source') AS Sources,
- FORMAT(CAST(JSON_VALUE(DATA, '$.extractor.rowsLoaded') AS INT), '#,0') AS RowsLoaded,
- --array 0
- FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.gobbler.processed') AS INT), '#,0') AS "Gobbler[1]",
- 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]",
- CONCAT(
- 'Qualigator [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.qualigator.processed') AS INT), '#,0'), '], ',
- 'Sinker [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.sinker.processed') AS INT), '#,0'), '], ',
- 'Final [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.finalTracking.processed') AS INT), '#,0'), ']'
- ) AS "Processed[1]",
- CONCAT(
- 'Qualigator [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.qualigator.rejected') AS INT), '#,0'), '], ',
- 'Sinker [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.sinker.rejected') AS INT), '#,0'), '], ',
- 'Final [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.finalTracking.rejected') AS INT), '#,0'), ']'
- ) AS "Rejected[1]",
- --array 1
- FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.gobbler.processed') AS INT), '#,0') AS "Gobbler[2]",
- 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]",
- CONCAT(
- 'Qualigator [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.qualigator.processed') AS INT), '#,0'), '], ',
- 'Sinker [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.sinker.processed') AS INT), '#,0'), '], ',
- 'Final [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.finalTracking.processed') AS INT), '#,0'), ']'
- ) AS "Processed[2]",
- CONCAT(
- 'Qualigator [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.qualigator.rejected') AS INT), '#,0'), '], ',
- 'Sinker [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.sinker.rejected') AS INT), '#,0'), '], ',
- 'Final [', FORMAT(CAST(JSON_VALUE(DATA, '$.streams.streams[1].state.finalTracking.rejected') AS INT), '#,0'), ']'
- ) AS "Rejected[2]",
- CONVERT(VARCHAR, DATEADD(HOUR, 7, StartTimestamp), 0) AS START,
- CONVERT(VARCHAR, DATEADD(HOUR, 7, CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.sinker.lastContactTimestamp') AS DATETIME2)), 0) AS Finish,
- DATEDIFF(mi, CAST(StartTimestamp AS DATETIME2), CAST(JSON_VALUE(DATA, '$.streams.streams[0].state.sinker.lastContactTimestamp') AS DATETIME2)) AS "Duration[min]"
- FROM Titanium..Jobs
- ORDER BY StartTimestamp DESC;
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement