The documentation is a bit spotty and I’m having some issues piecing this together. Would you have a pipeline example with the syntax listed here so I can sort of assemble my mind around this? I think once I get the idea it will become clear.
You should rewrite it based on your needs, but here is a working example.
rule "elastic server address"
when
contains(to_string($message.message), "Retrying request to")
then
set_field("elastic_ip", regex("http://(.*):9200" ,to_string($message.message))["0"]);
end
The pipeline can encode base64, I would store the encoded version also, maybe it is better for search.