elasticsearch 相关问题

Elasticsearch是一个基于Lucene的开源（Apache 2），分布式，RESTful，搜索引擎。

Pyspark 将数据从 Kafka 主题流式传输到弹性搜索索引，在 Jupyter 笔记本中运行，导致失败

我正在通过 Jupyter Notebook 中的 Pyspark 从 Kafka 主题流式传输数据。我们正在将流写入 Elasticsearch 索引。加载到 HDFS 时出现此错误，但工作正常。驱动程序堆栈...

apache-spark elasticsearch pyspark

回答 1 投票 0

OData 服务与 Elastic 搜索

我是 OData 服务的新手。我编写了一个查询来检索具有空值的特定字段。我在 OData 中构建查询并将其传递到弹性搜索以检索数据。但查询似乎...

elasticsearch odata

回答 2 投票 0

Logstash 无法使用beats 输入通过单个端口接收所有事件

我们面临一个问题，即我们无法同时从使用

elasticsearch logstash elastic-stack logstash-configuration

回答 1 投票 0

langchain索引规范中的ElasticsearchDatabaseChain

从elasticsearch导入Elasticsearch 从 langchain.chat_models 导入 ChatOpenAI 从 langchain.chains.elasticsearch_database 导入 ElasticsearchDatabaseChain ELASTIC_SEARCH_SERVER = "ht...

elasticsearch streamlit openai-api langchain large-language-model

回答 1 投票 0

如何使用LocalDate从spring查询elasticsearch

有这个搜索查询：最终 SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(QueryBuilders.rangeQuery("updateTime").gte(LocalDate.now())).build(); 最终名单有此搜索查询： final SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(QueryBuilders.rangeQuery("updateTime").gte(LocalDate.now())).build(); final List<ActivityValue> listOf = elasticsearchTemplate.queryForList(searchQuery, ActivityValue.class); 使用实体 ActivityValue： @Document(indexName = "tracking1", type = "activity") public class ActivityValue { @Id private String id; @Field(type = FieldType.Date, index = false, store = true, format = DateFormat.custom, pattern = "yyyy-MM-dd") @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd") private LocalDate updateTime; @Field(type = FieldType.Object, includeInParent = true) private Vendor vendor; @Field(type = FieldType.Object, includeInParent = true) private QCriteria quality; public ActivityValue() { } //setter and getter } 如果我运行查询并尝试接收列表，我会收到以下异常： caused by: java.io.IOException: can not write type [class java.time.LocalDate] 实体之前存储的实际日期为LocalDate。我不确定查询 Elasticsearch 并解决此错误的最佳/最简单方法是什么。有人可以帮忙吗？ final SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(QueryBuilders.rangeQuery("updateTime").gte(LocalDate.now().toString())).build(); final List<ActivityValue> listOf = elasticsearchTemplate.queryForList(searchQuery, ActivityValue.class); 我通过使用 LocalDate.now().toString() 而不是 LocalDate.now() 解决了这个问题而是使用自定义模式（您还必须在任何 @Field 上设置），您可以从 objectmapper 禁用默认行为。默认行为是将 LocalDate 转换为时间戳。 //For LocalDateTime usage final ObjectMapper objectMapper = new ObjectMapper().registerModule(new JavaTimeModule()); objectMapper.configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, false); final JacksonJsonpMapper jsonpMapper = new JacksonJsonpMapper(objectMapper); 这样做，您可以确保自动以 yyyy-MM-ddThh:mm:ss.SSSZ 格式存储，而不是在 epoc 时间后的几毫秒内存储。现在您可以将数据设置为： static class Data { private LocalDateTime dateTime; } 并使用类似于以下的查询进行搜索： RangeQuery rangeQuery = new RangeQuery.Builder().field("dateTime").lt(JsonData.of(LocalDateTime.now())).build(); 没有问题或任何额外的努力。

spring elasticsearch

回答 2 投票 0

rsyslog - 完全关闭 $RepeatedMsgReduction

目前，我的 Docker 映像中的 $RepeatedMsgReduction 设置为打开。该镜像充当其他几个 Docker 镜像的基础镜像。关闭此功能会产生什么影响，尤其是在神灵中......

elasticsearch syslog rsyslog

回答 1 投票 0

Elasticsearch查询获取多个属性的值

我有以下json数据： { "_index": "日志", “_type”：“_doc”， “_id”：“122”， “_版本”：7， “_score”：空， ...

json elasticsearch

回答 1 投票 0

如何将主机端口映射到容器端口，该端口默认情况下不在docker compose的elasticsearch容器中

我在linux（ubunut 24.04 lts）中的docker compose中使用官方的elasticsearch docker容器镜像。我正在处理不同的项目，每个项目中都有弹性搜索容器映像...