Интеграция logstash (elk) с mulesoft

Question

Есть ли способ, которым мы могли бы кормить журналы мух облаков в logstash?

Я могу настроить агентов, как в этой ссылке

https://docs.mulesoft.com/cloudhub/sending-data-from-arm-to-external-monitoring-software

Но я не могу настроить logstash.

Answer 1

Вы можете использовать app app log4j socket, если cloudhub позволяет подключаться к внешнему серверу. Вы можете настроить logstash для прослушивания tcp для журналов, вы можете обратиться к этому, https://www.elastic.co/guide/en/logstash/current/plugins-inputs-tcp.html. Вот пример ввода tcp для logstash (https://gist.github.com/jgoodall/6323951), убедитесь, что вы установили правильный формат для мула, потому что возникла бы проблема с многострочными данными. также настроить приложение, для более старой версии мула, вы можете добавить log4j.xml

<?xml version="1.0" encoding="UTF-8" ?> 
<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd"> 

<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/"> 
    <appender name="console" class="org.apache.log4j.ConsoleAppender"> 
    <param name="Target" value="System.out" /> 
    <layout class="org.apache.log4j.PatternLayout"> 
     <param name="ConversionPattern" value="%d{dd-MM-yyyy HH:mm:ss} %-5p [%t] [%c] - %m%n" /> 
    </layout> 
    <filter class="org.apache.log4j.varia.LevelRangeFilter"> 
     <param name="LevelMin" value="ERROR" /> 
     <param name="LevelMax" value="FATAL" /> 
     <param name="AcceptOnMatch" value="true" /> 
    </filter> 
</appender> 
<appender name="socket" class="org.apache.log4j.net.SocketAppender"> 
    <param name="Threshold" value="INFO" /> 
    <param name="application" value="AppName" /> 
    <param name="Port" value="4560" /> 
    <param name="RemoteHost" value="remotehost.com" /> 
    <param name="ReconnectionDelay" value="60000" /> 
    <layout class="org.apache.log4j.PatternLayout"> 
     <param name="ConversionPattern" value="%d{dd-MM-yyyy HH:mm:ss} %-5p [%t] [%c] - %m%n" /> 
    </layout> 

</appender> 

<appender name="asyncConsole" class="org.apache.log4j.AsyncAppender"> 
    <param name="BufferSize" value="200"/> 
    <appender-ref ref="console"/> 
</appender> 

<appender name="asyncFile" class="org.apache.log4j.AsyncAppender"> 
    <param name="BufferSize" value="200"/> 
    <appender-ref ref="file"/> 
</appender> 

<appender name="asyncSocket" class="org.apache.log4j.AsyncAppender"> 
    <param name="BufferSize" value="200"/> 
    <appender-ref ref="socket"/> 
</appender> 

<logger name="Tracking" additivity="false"> 
    <level value="warn" /> 
    <appender-ref ref="asyncConsole" /> 
    <appender-ref ref="asyncFile" /> 
    <appender-ref ref="asyncSocket" /> 
</logger> 

<logger name="com.mulesoft.module.datamapper" additivity="false"> 
    <level value="warn" /> 
    <appender-ref ref="asyncConsole" /> 
    <appender-ref ref="asyncFile" /> 
    <appender-ref ref="asyncSocket" /> 
</logger> 

<logger name="org.mule.api.processor.LoggerMessageProcessor" additivity="false"> 
    <level value="info" /> 
    <appender-ref ref="asyncConsole" /> 
    <appender-ref ref="asyncFile" /> 
    <appender-ref ref="asyncSocket" /> 
</logger> 
<root> 
    <priority value="info" /> 
    <appender-ref ref="asyncConsole" /> 
    <appender-ref ref="asyncFile" /> 
    <appender-ref ref="asyncSocket" /> 
</root> 

Обратите внимание на разъем Appender, оттуда можно настроить хост и порт logstash экземпляра. Для более новой версии mule существует log4j2.xml, конфигурация для приложения-сокета похожа.