How to use vector to filter log keywords, for example, trigger telegram alarm if more than 3 times within 5 minutes, thank you very much

[qooke]

vector.toml

data_dir = "/opt/vector/data"
timezone = "Asia/Hong_Kong"

[api]
enabled = true
address = "127.0.0.1:8686"

[sources.log_source]
type = "file"
include = ["/data/logs/api/api.log"]
ignore_older_secs = 600

[transforms.info_filter]
type = "filter"
inputs = ["log_source"]
condition = 'contains(string(.message) ?? "", "INFO")'

[transforms.json_encoder]
type = "remap"
inputs = ["info_filter"]
source = '''
. = { "text": "[LOG ALERT] \n" + string(.message) }
'''

[sinks.telegram_sink]
type = "http"
inputs = ["json_encoder"]
uri = "https://api.telegram.org/botxxxxxxxx:xxxxxxxxxxxxxx/sendMessage"
method = "post"
encoding.codec = "json"

[ sinks.telegram_sink.headers ]
Content-Type = "application/json"

[ sinks.telegram_sink.request ]
body = '''
{
  "chat_id": "-xxxxxxxx",
  "text": "{{ text }}"
}
'''

error.log

Mar 12 10:58:41 test vector[1514]: √ Loaded ["/opt/vector/config"]
Mar 12 10:58:41 test vector[1514]: Component errors
Mar 12 10:58:41 test vector[1514]: ----------------
Mar 12 10:58:41 test vector[1514]: x Transform "json_encoder":
Mar 12 10:58:41 test vector[1514]: error[E103]: unhandled fallible assignment
Mar 12 10:58:41 test vector[1514]: ┌─ :1:5
Mar 12 10:58:41 test vector[1514]: │
Mar 12 10:58:41 test vector[1514]: 1 │ . = { "text": "[LOG ALERT] \n" + string(.message) }
Mar 12 10:58:41 test vector[1514]: │ --- ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ this expression is fallible because at least one argument's type cannot be verified to be valid
Mar 12 10:58:41 test vector[1514]: │ │
Mar 12 10:58:41 test vector[1514]: │ or change this to an infallible assignment:
Mar 12 10:58:41 test vector[1514]: │ ., err = { "text": "[LOG ALERT]
Mar 12 10:58:41 test vector[1514]: " + string(.message) }
Mar 12 10:58:41 test vector[1514]: │
Mar 12 10:58:41 test vector[1514]: = see documentation about error handling at https://errors.vrl.dev/#handling
Mar 12 10:58:41 test vector[1514]: = see functions characteristics documentation at https://vrl.dev/expressions/#function-call-characteristics
Mar 12 10:58:41 test vector[1514]: = learn more about error code 103 at https://errors.vrl.dev/103
Mar 12 10:58:41 test vector[1514]: = see language documentation at https://vrl.dev
Mar 12 10:58:41 test vector[1514]: = try your code in the VRL REPL, learn more at https://vrl.dev/examples
Mar 12 10:58:41 test systemd[1]: vector.service: control process exited, code=exited status=78
Mar 12 10:58:41 test systemd[1]: Failed to start Vector.