Histórico da Página

📘 Documentação Oficial - Integração LogClient Protheus com Fluent Bit + Grafana

...

🔧 Objetivo Geral

Integrar o LogClient (sistema de logs proprietário do Protheus) ao Fluent Bit com o objetivo de encaminhar os logs para uma estrutura centralizada e visualizá-los no Grafana. Para isso, será usado um script de parsing em Lua e um agente td-agent-bit (Fluent Bit).

...

🚀 1. Implantação

📥 Requisitos:

• Protheus com LogClient configurado para saída via TCP;

• Fluent Bit instalado (td-agent-bit);

• Acesso root ao servidor de integração;

• Script parser_logclient.lua (presente nesta documentação);

• Configuração do td-agent-bit.conf com entrada, filtro e saída.

🧱 Estrutura Geral:

[Protheus LogClient] → TCP (porta específica)
      ↓
[Fluent Bit (td-agent-bit)] → [Script Lua] → Envio HTTP/Elastic → Grafana

📂 Instalação do Fluent Bit (Ubuntu/Debian):

sudo apt-get install td-agent-bit

🛠️ Configuração do td-agent-bit.conf (exemplo básico):

[SERVICE]
    Flush        5
    Daemon       Off
    Log_Level    info

[INPUT]
    Name        tcp
    Listen      0.0.0.0
    Port        5170
    Format      json
    Tag         logclient

[FILTER]
    Name        lua
    Match       logclient
    script      /opt/td-agent-bit/parser_logclient.lua
    call        parse_logmsg

[OUTPUT]
    Name        http
    Match       logclient
    Host        logs.meuserver.com
    Port        443
    URI         /api/logs
    Format      json
    Header      Authorization Bearer TOKENX
    Compress    gzip

📜 Permissões:

Certifique-se de que o script .lua tem permissão de leitura:

chmod +r /opt/td-agent-bit/parser_logclient.lua

...

🔍 2. Script Lua para Tratamento dos Logs

📄 Caminho sugerido: /opt/td-agent-bit/parser_logclient.lua

function parse_logmsg(tag, timestamp, record)
    if not record["log"] then
        return 0, timestamp, record
    end

    local log = record["log"]
    local final_log = ""
    local space_found = false

    for i = 1, #log do
        local c = log:sub(i, i)
        if c ~= " " then
            final_log = final_log .. c
            space_found = false
        elseif not space_found then
            final_log = final_log .. c
            space_found = true
        end
    end

    final_log = final_log:gsub('\\"', '"')
    local keyValuePart = final_log:match("|(.*)|")

    if keyValuePart then
        local parts = split_string(keyValuePart, "|")
        for _, part in ipairs(parts) do
            local field, value
            if part:match("^Variavel=") then
                field, value = "Variavel", part:sub(10)
            elseif part:match("^Mensagem=") then
                field, value = "Mensagem", part:sub(10)
            else
                field, value = part:match("([^=]+)=([^=]+)")
            end

            if field and value then
                value = value:gsub('\\"', '"')
                local num_value = tonumber(value)
                if num_value then
                    record[field:trim()] = num_value
                else
                    record[field:trim()] = value:trim()
                end
            end
        end

        if not record["Tabela"] or record["Tabela"] == '' or record["Tabela"] == nil then
            record["Tabela"] = "_"
        end

        local valueBeforePipe = final_log:match("^(.-)%s*|")
        if valueBeforePipe then
            local date, machineName, machineIp, routine, routineId = valueBeforePipe:match("^%d+ <%d+>%d+ ([%d%-T:.]+)%S* ([%w%-]+)%(([%d%.]+)%)%((%d+)%) (%w+)%s(%d+)%s")

            if machineName or machineIp or routine or routineId then
      

Para a utilização do Agente https://fluentbit.io/ recebendo dados da integração [LogClient] .

O fluxo abaixo exemplifica bem o processo:

Image Removed

Processo de Configuração

...

editar o arquivo:
/etc/td-agent-bit/td-agent-bit.conf

...

...

...

record["MachineName"] = machineName
                record["MachineIp"] = machineIp
                record["Routine"] = routine
         

...

...

record["RoutineId"] = routineId
        

...

    end
        

...

end

    

...

    if record["Data"] and (not 

...

record["HoraAtualizacao"] or not record["HoraAlteracao"]) then
    

...

        if not 

...

record["HoraAtualizacao"] then
    

...

            record["HoraAtualizacao"] = record["Data"]
            

...

end
    

...

        if 

...

not record["HoraAlteracao"] then
      

...

          record["HoraAlteracao"] 

...

= record["Data"]
    

...

...

end
   

...

     end
    

...

else
        record["log"] = nil
    end

    return 1, timestamp, record
end

function split_string(input, delimiter)
    

...

local result = {}
    

...

for match in (input .. delimiter):gmatch("(.-)" .. delimiter) do
    

...

    table.insert(result, match)
    

...

end
    return 

...

result
end

function string:trim()
    

...

return self:match("^%s*(.-)%s*$")
end

...

👨‍🔧 3. Manutenção

• 🔄 Reiniciar o Fluent Bit após qualquer alteração no .conf ou .lua:

sudo systemctl restart td-agent-bit

• 📋 Logs do agente Fluent Bit:

journalctl -u td-agent-bit -f

• 🔐 Tokens expiram? Certifique-se de atualizar o token da API do Grafana ou servidor de logs na seção [OUTPUT].

...

🎓 4. Formação Técnica e Treinamento

• 👨‍🏫 Recomenda-se formação básica em:

  • Protheus (LogClient);

  • Shell script (Linux);

  • Configuração Fluent Bit;

  • Leitura e escrita básica em Lua.

• 💡 Dica prática:
  Use o seguinte comando para testar se a porta TCP está aberta:

nc -vz localhost 5170

...

📞 Suporte
Em caso de dúvidas ou erros:

• Verifique logs do td-agent-bit e do Protheus.

• Teste o script .lua isoladamente.

• Valide se os logs estão chegando no Grafana ou outro destino configurado.