Место общения программистов C#
Anonymous
ElasticSearch Nest BulkAll остановлен после получения ошибок, которые невозможно повторить из _bulk
Сообщение
Anonymous » 19 ноя 2024, 16:59
Используя BulkAll() для массовой вставки, я получаю эту странную ошибку
Код: Выделить всё
BulkAll halted after receiving failures that can not be retried from _bulk
Однако я все еще получаю успешный ответ при проверке исключения:
Код: Выделить всё
Successful low level call on POST: /cf-lblogs-2019.01.23/cloudflareloadbalancinglogelasticentity/_bulk?
Что я здесь делаю не так? Ниже приведен фрагмент кода:
Код: Выделить всё
var waitHandle = new CountdownEvent(1);
var bulk = _client.BulkAll(group.ToList(), a => a
.Index(_index.Replace("*", string.Empty) + group.Key)
.BackOffRetries(2)
.BackOffTime("30s")
.RefreshOnCompleted(true)
.MaxDegreeOfParallelism(4)
.Size(group.Count()));
bulk.Subscribe(new BulkAllObserver(
onNext: response => _logger.LogInformation($"Indexed {response.Page * group.Count()} with {response.Retries} retries"),
onError: HandleInsertError,
onCompleted: () => waitHandle.Signal()
));
waitHandle.Wait();
private void HandleInsertError(Exception e)
{
var exceptionString = e.ToString();
_logger.LogError(exceptionString);
}
Nest 6.4.2.
Elastic 6.5.4.
Подробнее здесь:
https://stackoverflow.com/questions/543 ... t-be-retri
1732024742
Anonymous
Используя BulkAll() для массовой вставки, я получаю эту странную ошибку [code]BulkAll halted after receiving failures that can not be retried from _bulk [/code] Однако я все еще получаю успешный ответ при проверке исключения: [code]Successful low level call on POST: /cf-lblogs-2019.01.23/cloudflareloadbalancinglogelasticentity/_bulk? [/code] Что я здесь делаю не так? Ниже приведен фрагмент кода: [code]var waitHandle = new CountdownEvent(1); var bulk = _client.BulkAll(group.ToList(), a => a .Index(_index.Replace("*", string.Empty) + group.Key) .BackOffRetries(2) .BackOffTime("30s") .RefreshOnCompleted(true) .MaxDegreeOfParallelism(4) .Size(group.Count())); bulk.Subscribe(new BulkAllObserver( onNext: response => _logger.LogInformation($"Indexed {response.Page * group.Count()} with {response.Retries} retries"), onError: HandleInsertError, onCompleted: () => waitHandle.Signal() )); waitHandle.Wait(); private void HandleInsertError(Exception e) { var exceptionString = e.ToString(); _logger.LogError(exceptionString); } [/code] Nest 6.4.2. Elastic 6.5.4. Подробнее здесь: [url]https://stackoverflow.com/questions/54348798/elasticsearch-nest-bulkall-halted-after-receiving-failures-that-can-not-be-retri[/url]
0 Ответы
25 Просмотры
Последнее сообщение Anonymous
17 янв 2025, 10:25
ElasticSearch Nest пропустил данные InnerHits
Anonymous »
04 окт 2024, 14:50 » в форуме
C#
Я пытаюсь получить данные из вложенного поля (используя внутренние обращения)
{
track_total_hits : true,
from : 0,
query : {
bool : {
must : [
{
nested : {
inner_hits : {},
path : physical_info_list ,
query : {
bool : {
must :
}
}
}
}...
0 Ответы
25 Просмотры
Последнее сообщение Anonymous
04 окт 2024, 14:50
Поиск Elasticsearch и FScrawler с оценкой с использованием Nest
Anonymous »
07 мар 2025, 15:10 » в форуме
C#
Я настраиваю Elasticsearch и fscrawler для индексации документов.
Теперь план состоит в том, чтобы разработать небольшое приложение, полученное результаты и набрать их по большинству попадания. serach
class FSDocuments
{
public FSFile File { get;...
0 Ответы
17 Просмотры
Последнее сообщение Anonymous
07 мар 2025, 15:10
EF Bulk Extensions для меня работает очень медленно, но почему?
Anonymous »
04 дек 2024, 20:11 » в форуме
C#
У меня есть консольное приложение C# .Net 6.0, использующее EF Core 6.0.35
Я делаю вызов API для получения данных (из Geotab), которые фильтрую, преобразую и вставляю в свою базу данных. Каждая вставка содержит от 1000 до 2000 записей.
Моя таблица:...
0 Ответы
13 Просмотры
Последнее сообщение Anonymous
04 дек 2024, 20:11
EF Bulk Extensions для меня работает очень медленно, но почему?
Anonymous »
04 дек 2024, 21:32 » в форуме
C#
У меня есть консольное приложение C# на .NET 6.0, использующее EF Core 6.0.35.
Я делаю вызов API, чтобы получить данные (из Geotab), которые я фильтрую, преобразую и вставить в мою БД. Каждая вставка содержит от 1000 до 2000 записей.
Моя таблица в...
0 Ответы
13 Просмотры
Последнее сообщение Anonymous
04 дек 2024, 21:32