#elasticsearch #kibana #fluentd #td-agent
Вопрос:
Я установил td-agent
в Ubuntu18
. td-agent.conf
файл выглядит так, как показано ниже:
<source>
@type tail
path /home/thingtrax/Documents/ThingTraxDevice/pi/logs/zigbee/TX-S2-SKL-035_cycle.json
pos_file /home/thingtrax/Documents/ThingTraxDevice/pi/logs/zigbee/TX-S2-SKL-035_cycle.json.pos
format json
time_format %Y-%m-%d %H:%M:%S
tag health035
</source>
<filter **>
@type record_transformer
<record>
hostname ${hostname}
Customer "SKL"
Version "V2"
</record>
</filter>
<filter *035*>
@type record_transformer
<record>
EquipmentId "ACCUPACK3GD3"
</record>
</filter>
<match health035>
@type elasticsearch
hosts https://search-ttproduction-7fzlahn2oj4ofkkw2vre.eu-west-2.es.amazonaws.com/
user john
password admin@123
index_name health_skl_035
type_name health
</match>
Выше файл агента td является образцом файла, но у меня есть 70 исходных файлов, в которые я загружаю данные elasticsearch
, и аналогично у меня есть 70 файлов совпадений. Итак, файл агента td огромен, и именно поэтому я только что показал его для 1 исходного файла. Теперь проблема в том, что агент td может загружать все данные в elasticsearch, и я также могу видеть данные в elasticsearch. Но все равно я продолжаю получать предупреждение или ошибку ниже в файле журнала агента td:
2021-07-07 05:56:24 0000 [предупреждение]: #0 дамп события ошибки: error_class=Fluent::Плагин::ElasticsearchErrorHandler::Ошибка ElasticsearchError=»400 — Отклонено Elasticsearch» местоположение=ноль тег=»health035″ время=2021-07-07 05:55:22.785788722 0000 запись={«Идентификатор входа»=>2, «вход_1″=>>1, «input_2″=>>>4, «NodeID»=>>>>0, «Прошивка»=>>>>>7, «счетчик»=>>>>>>109, «идентификатор датчика»=>>>>>>>244, «Имя датчика»=>>>>>>>>»Другое», «MsgMissed»=>>>>>>>>>0, «is_health»=>>>>>>>>>>»Да», «Сила сигнала»=>>>>>>>>>>>74, «создано»=>>>>>>>>>>>>»2021-07-07T05:55:22.785491», «MacGateway»=>»0013A20041AEC6AA», «MacAdress_Sensor»=>»0013A20041C3672E», «трансляции»=>»нет», «свойство DeviceID»=>»Техас-С2-СКЛ-035», «имя»=>»Техас-Г1-318», «клиент»=>»СКЛ», «версия»=>»В2», «EquipmentId»=>»ACCUPACK3GD3»}
Я не в состоянии понять это сообщение об ошибке, как в нем говорится Rejected by Elasticsearch
, но все же я могу видеть данные в elasticsearch. Означает ли эта ошибка, что я загружаю много данных, и из-за трафика некоторые данные между ними отклоняются elastisearch? Если это правда, может ли кто-нибудь предложить, как я могу обрабатывать много данных, так как у меня есть 70 файлов журналов, для которых мне нужно загрузить данные в elasticsearch.
Может ли кто-нибудь, пожалуйста, предположить, что означает эта ошибка. Пожалуйста, помогите, спасибо.