diff options
| author | chaochaoc <[email protected]> | 2024-11-18 14:59:23 +0800 |
|---|---|---|
| committer | chaochaoc <[email protected]> | 2024-11-18 15:00:49 +0800 |
| commit | 2735b8e93e6284ad54d88bc951f0e764fbc449d2 (patch) | |
| tree | 39e870f61bb8b538c0baed6407c3d472062d6233 | |
| parent | 557c6f23ebb1394e9626c856f511c6500716361c (diff) | |
[TSG-23814] fix: fix some bugs
| -rw-r--r-- | src/main/resources/jobs/job.yml | 23 |
1 files changed, 13 insertions, 10 deletions
diff --git a/src/main/resources/jobs/job.yml b/src/main/resources/jobs/job.yml index 1c5fd4a..1731409 100644 --- a/src/main/resources/jobs/job.yml +++ b/src/main/resources/jobs/job.yml @@ -338,12 +338,14 @@ pipeline: where: NOT(IS_IP_ADDRESS(client_ip)) || NOT(IS_IP_ADDRESS(server_ip)) || client_port.isNull || client_port <= 0 || server_port.isNull || server_port <= 0 # Invalid stream dir - name: error2-records - where: decoded_as == 'SIP' &&STREAM_DIR(flags) != 1 && STREAM_DIR(flags) != 2 && STREAM_DIR(flags) != 3 + where: decoded_as == 'SIP' && STREAM_DIR(flags) != 1 && STREAM_DIR(flags) != 2 && STREAM_DIR(flags) != 3 # Invalid: SIP one-way stream and has invalid network address - name: error3-records where: decoded_as == 'SIP' && ( NOT(HAS_IP_ADDRESS(sip_originator_sdp_connect_ip, sip_responder_sdp_connect_ip)) || sip_originator_sdp_media_port.isNull || sip_originator_sdp_media_port <= 0 || sip_responder_sdp_media_port.isNull && sip_responder_sdp_media_port <= 0 ) - name: error4-records where: decoded_as == 'SIP' && STREAM_DIR(flags) == 3 && ( NOT( IS_IP_ADDRESS(sip_originator_sdp_connect_ip) ) || NOT( IS_IP_ADDRESS(sip_responder_sdp_connect_ip) ) ) + - name: error5-records + where: decoded_as == 'SIP' && sip_call_id.isNull ### Notes: If internal IP address correlate is needed, please comment the following two items # # Invalid: SIP one-way stream and internal network address @@ -1570,10 +1572,10 @@ pipeline: @i.$ip_protocol AS ip_protocol, - @i.$sent_pkts + sent_pkts AS sent_pkts, - @i.$received_pkts + received_pkts AS received_pkts, - @i.$sent_bytes + sent_bytes AS sent_bytes, - @i.$received_bytes + received_bytes AS received_bytes, + @i.$sent_pkts AS sent_pkts, + @i.$received_pkts AS received_pkts, + @i.$sent_bytes AS sent_bytes, + @i.$received_bytes AS received_bytes, withColumns(sip_call_id to sip_bye_reason), @@ -1643,10 +1645,10 @@ pipeline: @i.$ip_protocol AS ip_protocol, - @i.$sent_pkts + sent_pkts AS sent_pkts, - @i.$received_pkts + received_pkts AS received_pkts, - @i.$sent_bytes + sent_bytes AS sent_bytes, - @i.$received_bytes + received_bytes AS received_bytes, + @i.$sent_pkts AS sent_pkts, + @i.$received_pkts AS received_pkts, + @i.$sent_bytes AS sent_bytes, + @i.$received_bytes AS received_bytes, @sip.$sip_call_id AS sip_call_id, @sip.$sip_originator_description AS sip_originator_description, @@ -1953,4 +1955,5 @@ pipeline: - error1-records - error2-records - error3-records - - error4-records
\ No newline at end of file + - error4-records + - error5-records
\ No newline at end of file |