Skip to content

ebonding-servicenow-to-stream-v2

Pipeline: ebonding-servicenow-to-stream-v2

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
## Create a bookmark for streaming data.
@c:bookmark-loop
        bookmark = 'ebonding-snow-incidents'
        & initial_value = '-1 hour'
        & offset_reset = "latest"
    --> @dm:empty

    --> @dm:addrow
            table="incident" &
            limit=0
    --> #snowv2:query-table
            sys_created_on is after '${bookmark}'
    ## write incident to the stream
    --> @rn:write-stream
            name = "snow-incidents"
    ## update bookmark
    --> @dm:save_bookmark
            name = 'ebonding-snow-incidents' &
            value_column = 'sys_created_on' &
            value_type = 'timestamp' &
            value_func = 'max'
    ## update stats
    --> @rn:write-stats-to-stream
            name = "ebonding-analytics" &
            groupby = "category,priority,severity,company" &
            type = "ServiceNow" &
            mode = "input"


Extensions used in this Pipeline

Source Name Extension Type
snowv2 servicenow_v2
rn rn


Artifacts used in this Pipeline

Artifact Type Artifact Name Access
rda-network-stream snow-incidents write
bookmark ebonding-snow-incidents write
rda-network-stream ebonding-analytics write


Bots used in this Pipeline

@c:bookmark-loop @dm:empty @dm:addrow #snowv2:query-table @rn:write-stream @dm:save_bookmark @rn:write-stats-to-stream