Hello,I have a stream, and i want to drop some event using pipeline.
I create a pipeline and connect to my stream.
Create two stage and two rule:
rule “src_ip”
when
true
then
let mess = to_string($message.message);
let parsed = grok(pattern: “%{IPV4:src_ip}”,value: mess);
set_fields(parsed);
end
rule “Remove”
when
has_field(“src_ip”) &&
cidr_match(“192.168.0.0/21”, to_ip($message.src_ip)) - for example
then
drop_message();
end
Copy RAW filebeats output to simulator:
Message would be dropped
The pipeline processor would drop such a message. That means that the message would not be stored , and would not be available for searches, alerts, outputs, or dashboards.
But if a launch filebeat to send logs - it’s not working.
Use drag and drop to change the execution order of the message processors.
AWS Instance Name Lookup
GeoIP Resolver
Pipeline Processor
Message Filter Chain