当前位置： 移动技术网 > IT编程>开发语言>.net > Elasticsearch.Net、Nest批量插入BulkAll

Elasticsearch.Net、Nest批量插入BulkAll

2019年04月27日  | 移动技术网IT编程  | 我要评论

育知同创,唐治平老婆,陈美诗吻戏

demo地址：bulkall

批量导入

实现目标：想要使用elasticsearch的 .net api客户端nest批量导入数据，并发异步高效的批量导入
nest提供了bulkall
不废话，上代码

            const int size = 1000;
            var tokensource = new cancellationtokensource();

            var observablebulk = elasticclient.bulkall(list, f => f
                    .maxdegreeofparallelism(8)
                    .backofftime(timespan.fromseconds(10))
                    .backoffretries(2)
                    .size(size)
                    .refreshoncompleted()
                    .index(indexname)
                    .buffertobulk((r, buffer) => r.indexmany(buffer))
                , tokensource.token);

            var countdownevent = new countdownevent(1);

            exception exception = null;

            var bulkallobserver = new bulkallobserver();

            observablebulk.subscribe(bulkallobserver);

            countdownevent.wait(tokensource.token);

如果想要对处理导入过程进行监控可以这么替换bulkallobserver

               var bulkallobserver = new bulkallobserver(
                onnext: response =>
                {
                    writeline($"indexed {response.page * size} with {response.retries} retries");
                },
                onerror: ex =>
                {
                    writeline("bulkall error : {0}", ex);
                    exception = ex;
                    countdownevent.signal();
                },
                () =>
                {
                    writeline("bulkall finished");
                    countdownevent.signal();
                });

还可以使用c#的local function特性，如下所示

            void oncompleted()
            {
                writeline("bulkall finished");
                countdownevent.signal();
            }

            var bulkallobserver = new bulkallobserver(
                onnext: response =>
                {
                    writeline($"indexed {response.page * size} with {response.retries} retries");
                },
                onerror: ex =>
                {
                    writeline("bulkall error : {0}", ex);
                    exception = ex;
                    countdownevent.signal();
                },
                oncompleted);

完成demo，请点击 bulkall 查看

您可能感兴趣的文章:

如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网