Как установить более высокий тайм-аут в классе
Это работает, если данные не очень большие. (например, до 5 МБ)
import eland as ed
df = ed.DataFrame('localhost:9200', 'kibana_sample_data_flights')
df.to_csv('abc.csv')
Но получаю ошибку тайм-аута через 10 секунд, если данные большие.
ConnectionTimeout: ConnectionTimeout caused by - ReadTimeoutError(HTTPSConnectionPool(host='xxx', port=xxx): Read timed out. (read timeout=10))
Есть ли способ изменить тайм-аут по умолчанию в этом классе?
stackoverflow.com/questions/28287261/…
—
21.12.2020 05:56
0
1
245
2
Перейти к ответу
Данный вопрос помечен как решенный
Ответы 2
Ответ принят как подходящий
Библиотека eland, на которой основана elasticsearch, позволяет установить параметр Timeout самостоятельно. А на странице PyPI для eland подробно рассказывается о том, как использовать библиотеки eland и elasticsearch вместе для выполнения ваших запросов.
Вы можете сделать запрос, используя elasticsearch и получить объект DataFrame, который вы затем to_csv без необходимости сильно менять код.
Надеюсь, мой ответ был полезен!
Это был правильный объект подключения, который мне нужно включить тайм-аут.
import eland as ed
from elasticsearch import Elasticsearch
es = Elasticsearch([{"host": "localhost", "port": 9200, "timeout": 120}])
df = ed.DataFrame(es, es_index_pattern = "kibana_sample_data_flights")
Другие вопросы по теме
API веб-перехватчиков Python
Упорядочить результаты запроса по пользовательской оценке, определенной в агрегировании
Kibana Tophits при преобразовании группы по полю не по всему полю
Поиск подстроки в Elastic Search Java
Почему запросы префиксов Lucene/Elasticsearch выполняются медленнее, чем запросы терминов?
Logstash извлекает данные из разных типов сообщений
Elastic Search Cloud — добавление ca для переиндексации
Запрос Elasticsearch по общим свойствам: ключевые слова и числовые значения
Как я могу получить только внутренние поля из источника в ElasticSearch?
Что означает SSSZZ в формате даты yyyy-MM-dd'T'HH:mm:ss.SSSZZ?
Похожие вопросы
Elasticsearch в списке карт DynamoDB
Условие IF в Elasticsearch DSL
Запрос возвращает [parsing_exception] [размер] запрос неправильно сформирован, нет start_object после имени запроса, с {line=1 & col=264}
Внутренности массива строк и объединенной строки в ElasticSearch
Elasticsearch Сопоставление родителей и детей и индексация
В вашем кластере не найдено активных узлов, Laravel, докер
Как связать пользовательские метаданные с индексом в Elasticsearch?
Vega Lite / Kibana - Отметка области не показывает значений
Может ли Skywalking создавать индексы ES с помощью политик жизненного цикла или шаблонов индексов?
Запрос данных денормализованного дерева в Elasticsearch