我想要更新现有的或批量插入新的。我如何使用批量索引API来实现它？我想做类似下面的事情，但它抛出了错误。基本上，我想批量插入多个具有相同索引和相同类型的文档。
浏览 9提问于2017-07-26得票数 0
回答已采纳
目前，我正在为我的数据库使用Firestore，并且我有一个用户集合。每当用户文档被创建或更新到用户集合时，云函数就会接收用户文档，并将其保存在El154搜索中。
我开始关注这个体系结构的可伸缩性。例如，假设数千个云函数开始一次向Elasticsearch写入文档，那么Elasticsearch将处理这个负载。谷歌云有更好的解决方案吗？例如，这些云函数能否在队列中写入用户文档，并在队列的另一端具有云功能，获取100个文档并将它们大容量写入Elasticsearch。
浏览 2提问于2021-07-17得票数 1
回答已采纳
以下代码从两个表table1和table2中提取数据，在字段3上对它们执行连接，并将其索引到Elasticsearch中。需要索引的总行数约为5亿行。该代码在一小时内插入了500万条记录，因此采用这种方式需要100个小时才能完成。有没有办法让它更快些？
浏览 1提问于2015-06-26得票数 0
MemSQL 建议对Columnstore表的插入性能进行改进。要明确的是，性能不是我的用例的问题，它利用了单个插入的colunstore。
浏览 0提问于2016-02-16得票数 2
回答已采纳
为了提高性能，我希望将文档批量发送到Elasticsearch，而不是逐个发送。我在上读到过有关elastic bulk API的文章我想我必须准备这里描述的请求体()，并将其传递给restclient的performRequest方法？是否有其他方法，例如，ES ja
浏览 3提问于2017-04-11得票数 6
回答已采纳
2回答
我是elasticsearch的新手。所以，如果我问了一个非常简单的问题，请原谅。我想得到不同的时间间隔，如1天，1周，1个月等。
在过去的一周里，我一直在挣扎。
浏览 0提问于2018-08-21得票数 1
回答已采纳
基于弹性搜索API文档for($i = 0; $i < 100; $i++) { 'index''my_value', ];基本上，您循环遍历每个文档，为每个文档添加相同的元数据，然后调用bulk函数来<
浏览 1提问于2017-03-21得票数 0
回答已采纳
我想从数据库中加载数据，并在MVC.NET项目中使用弹性搜索进行搜索，但由于我在数据库的表中有数据，我无法将它们全部转换为json，并使用弹性搜索在json中搜索。如何从mvc.net项目中的数据库中填充弹性搜索的数据。我不想要整个解决方案，因为这是不可能的，只是一个一般性和简短的解释。非常感谢。
浏览 3提问于2015-07-12得票数 2
回答已采纳
我正在尝试使用elasticsearch批量api将多条记录插入到一个索引中。我的JSON看起来像这样：request json 我在文档的末尾插入了一个新行(\\n)，但是我仍然得到了newline error。
浏览 51提问于2020-04-12得票数 1
回答已采纳
嗨，我需要向mongodb插入大约100,000条记录。我正在使用BulkWriteOperation接口插入一批记录。我拆分了整个页面，并将1000条记录插入到mongo中。如果批次中的任何一条记录插入失败，那么整个批次都不会被插入到mongo。有没有办法单独获得失败批处理的记录列表，这样我就可以进行递归并将剩余的记录插入到mongo中
浏览 2提问于2016-01-14得票数 3
我想使用ElasticSearch来索引数据项。这些项目每天(从外部源)进行批次更新--每批替换前一天开始的批处理。插入新批次后，可以删除昨天开始的旧批。数据项在文件中接收，由计划作业解析，然后应持久化到ElasticSearch。我希望只在ElasticSearch中保持简单，而不向进程添加另一个DB。
你会怎么做？
浏览 2提问于2014-10-03得票数 0
回答已采纳
我正在使用和一群工作人员从Twitter下载tweet并处理它们。我还有一个基于Hadoop的实例。我需要的是将收集到的每个tweet移动到该实例，但由于我正在处理大量数据，我不确定如何做到这一点。如何将数据移动到Elasticsearch？对收到的每条推文进行插入会不会太多？它的是否适用于此？我主要关心的是避免平台中的瓶颈。实际上，我现在没有使用Flume来获取tweet，因为我需要多个具有不同关键字的代理，并且每30分钟动态更新一次该关键字。
浏览 1提问于2015-01-22得票数 0
我的列表中有2000个条目，我试图通过API将这个列表插入到elasticsearch中，这只是一个批量请求。请在下面找到相同的代码。Car car : carList){ }
queue_size: 1000
当
浏览 3提问于2016-10-26得票数 0
1回答
我使用Flink弹性搜索接收器将记录批量插入到ES。备注：在将记录添加到大容量处理器之前，我无法执行操作，因为无法保证记录与ES同步？我只想在记录同步到Elasticsearch之后才进行操作
浏览 1提问于2021-02-11得票数 2
回答已采纳
我有一个存储过程up_InsertEmployees。我有一个将一批员工详细信息上传到web应用程序的功能。此功能使用上面提到的存储过程将员工详细信息插入到数据库中。存储过程如下所示 (@EmployeeUN, @LastName,City, BatchRef)
Values(@
浏览 3提问于2015-02-19得票数 1
1回答
批量批量大小对插入量的影响
、、、、
我使用SqlBulkCopy将100万条记录(每条记录大约有10列)的内容插入到数据库表中。当我更改批处理大小属性(bulkCopy.BatchSize)时，我在批量复制期间看到了一些不稳定的值。bulkCopy.ColumnMappings.Add(new SqlBulkCopyColumnMapping(kv.Key, kv.Value));}
当我不使用批次大小时然后我把批
浏览 4提问于2015-02-02得票数 2
回答已采纳
我正在尝试将Dataset API集成到我的输入管道中。在此集成之前，该程序使用tf.train.batch_join()，它启用了动态填充。因此，这将批量处理元素，并根据最小批次中最大的元素填充它们。我不能使用填充批次，因为图像的尺寸没有设定的阈值。图像宽度可以是任何值。我和我的合作伙伴使用tf.contrib.data.bucket_by_sequence()想出了解决这个问题的办法。bucket_batch_sizes=np.f
浏览 3提问于2018-06-22得票数 0
我对Java ThreaPoolExecutor很陌生，我编写了一些任务，以便在弹性搜索中索引文档。通过ThreaPoolExecutor执行该任务，并使其工作正常。duration); e.printStackTrace();}
有人告诉我，我的方法对于弹性搜索中的文档索引来说是完全意义的我没有使用IndexRequest，而是使用BulkRequest
public class ProdCatIndexTa
浏览 2提问于2018-10-10得票数 1
回答已采纳
我正在尝试使用Python API在elastic search中批量插入大量文档。import elasticsearch print r
浏览 1提问于2015-02-06得票数 1
我必须做批量插入，并需要什么是添加的I。这是一个基本的示例，它显示了我正在做的事情(这显然对性能来说很糟糕)。我正在寻找一种更好的方法来做到这一点。}在上面的情况下，persist是一个在内部调用有没有什么优化的方法来取回Is并在此基础上批量插入
浏览 0提问于2011-12-21得票数 1
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
