pythonlogstash不工作了

Question

我有一个elasticsearch集群（ELK）和一些节点使用filebeat向logstash发送日志。
最近我添加了一个新的应用服务器，它使用python-logstash向我的logstash发送日志。在

我的logstash输入配置如下所示：

input {
   beats {
     type => beats
     port => 5044
   }
   udp {
     port => 5044
   }
}

我的应用服务器成功地将日志发送到logstash。在我的logstash机器上，我尝试运行以下命令：

^{pr2}$

x.x.x.x是我的应用服务器的ip。在

我的代码是：

self.logger=logging.getLogger(logger_name)
self.logger.addHandler(logstash.UDPLogstashHandler(ELASTICSEARCH_LOGSTASH_SERVER, 5044, version=1, message_type='bla',fqdn=elastic_fqdn))

elastic_fqdn是托管服务器的主机名。在

我可以看到这些包，它们看起来很好（udp，端口5044），但我在kibana/elasticsearch中看不到任何文档。在

感谢您的帮助：）