如果数据不是很大,这是可行的。(例如,最大5 MB)
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))
是否存在修改该类中默认超时的方法?
这是我需要包含超时的正确连接对象。
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")
库 eland
基于 elasticsearch
,允许您自己设置 Timeout 参数。eland
的PyPI页面详细说明了如何使用eland
和elasticsearch
库来提出请求。
您可以使用< code>elasticsearch发出请求,并获得一个< code>DataFrame对象,然后将该对象< code >转换为_csv,而无需对代码做太多修改。
我希望我的回答有帮助!
问题内容: 我org.springframework.ws.client.core.WebServiceTemplate用于拨打Web服务。如何为通话配置超时。 问题答案: 如果你使用的是Spring Webservices 2.1.0版本,则可以使用HttpComponentsMessageSender设置超时。 Spring不推荐使用CommonsHttpMessageSender,因此不再推
我正在尝试在我的WebClient上设置超时,以下是当前代码: 我需要添加超时和池策略,我在想这样的事情: 但是我不知道如何在我的webclient中设置httpClient
问题内容: 我正在尝试在使用http.request且没有运气的HTTP客户端上设置超时。到目前为止,我所做的是: 有什么提示吗? 问题答案: 现在可以使用option和相应的request事件:
问题内容: 我在我的应用程序中使用Retrofit库,我想将超时设置为60秒。改装有某种方法可以做到这一点吗? 我以这种方式设置Retrofit: 如何设置超时时间? 问题答案: 您可以在基础HTTP客户端上设置超时。如果未指定客户端,则Retrofit将使用默认的连接和读取超时创建一个客户端。要设置自己的超时时间,您需要配置自己的客户端并将其提供给。 一种选择是使用也是来自Square 的OkH
但我想要的是这样的