将数据从 apache kafka 流式传输到 apache spark,然后流式传输到 ubuntu 中的 elasticsearch
作者:Ilyas Ch 提问时间:11/16/2023
我想用python脚本通过apache spark从apache kafka主题中读取数据,然后对数据进行一些操作,然后实时流式传输到elasticsearch;最终,我将构建一个模型来对数据执行,并...
elasticsearch 问答列表
作者:Ilyas Ch 提问时间:11/16/2023
我想用python脚本通过apache spark从apache kafka主题中读取数据,然后对数据进行一些操作,然后实时流式传输到elasticsearch;最终,我将构建一个模型来对数据执行,并...
作者:alamelu 提问时间:11/17/2023
Elastic Server 8.8.2 的 Elasticsearch-rest-high-level-client 和 elasticsearch-rest-client maven 依赖项 我...
作者:John 提问时间:12/10/2021
我有一个场景,我想使用 SQS 触发 Lambda 函数来索引 Elasticsearch 中的文档。我遇到的问题是,排队的消息数将从 0 到数十万不等,具体取决于应用程序活动。 为了避免 Elas...
作者:RobertPro 提问时间:11/16/2023
我在尝试进行简单查询时遇到问题,请参阅以下数据: 拥有此数据: POST test/_doc/1 { "id": 1, "title": "Test Name" } POST test/_d...
作者:Nicholas O'Connell 提问时间:11/17/2023
我设置了 Amazon OpenSearch Service。我正在我的 Laravel php 服务中使用: 版本 7.17.2 来创建一个客户端。我知道这是用于 OpenSearch 的错误客户端...
作者:Ilyas Ch 提问时间:11/17/2023
我正在尝试通过apache spark将一些数据从apache kafka发送到elasticsearch,现在我正在测试管道,但仍然遇到一些错误,最终我将构建一个机器学习模型来对spark中的传入数...
作者:Michel van Engelen 提问时间:11/17/2023
我们安装了 size 插件,用于在 Kibana 中查找对我们资源有很大影响的日志项。 这导致: 能够在搜索栏中使用_size,例如:_size > 1000(这有效)。 可用字段列表中缺少_si...
作者:UnsatisfiedDependency 提问时间:4/29/2021
我在 Java 8 中有一个 BoolQueryBuilder 对象: BoolQueryBuilder ogObject; // Having some clauses already 我想将 ...
作者:Ben Rahim 提问时间:11/30/2022
我是 Elasticsearch 的新手。例如,我有一个值列表: id_list=[1111,2222,3333,4444,5555] 现在,我想匹配其中的这些ID,以匹配存储在Elastics...
作者:Gabii Enríquez 提问时间:11/23/2022
mapping = { "mappings": { "properties": { "Id_centro":{ "type": "keyword" }, "RFC":{ "type": "te...