备案控制台
开发者社区 数据库 文章 正文

关于文档的API操作( 更新文档和 批量插入)

2022-11-07 191
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
检索分析服务 Elasticsearch 版，2核4GB开发者规格 1个月
推荐场景：
数据可视化分析航班信息
简介： 关于文档的API操作( 更新文档和 批量插入)

更新文档

package com.wyh;
import com.alibaba.fastjson.JSON;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.wyh.config.ElasticSearchClientConfig;
import com.wyh.entity.User;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.Request;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;
import org.elasticsearch.client.indices.GetIndexRequest;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
import org.elasticsearch.search.suggest.completion.RegexOptions;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.TestPropertySource;
import javax.annotation.Resource;
import java.io.IOException;
/**
 * 测试es7.6.1 高级客户端API操作
**/
@SpringBootTest
class WyhApplicationTests {
//注入bean
    @Resource
private RestHighLevelClient client;
//更新文档信息
    @Test
void testUpdateDocument() throws IOException {
//更新请求
        UpdateRequest updateRequest = new UpdateRequest("wei_index","1");
//超时时间 1s
        updateRequest.timeout("1s");
//创建user对象
        User user = new User("魏二鹤", 18);
//对象转json
        String jsonString = JSON.toJSONString(user);
        updateRequest.doc(jsonString,XContentType.JSON);
        UpdateResponse updateResponse = client.update(updateRequest, RequestOptions.DEFAULT);
        System.out.println(updateResponse);
        System.out.println(updateResponse.status());
//UpdateResponse[index=wei_index,type=_doc,id=1,version=2,seqNo=1,primaryTerm=1,result=updated,shards=ShardInfo{total=2, successful=1, failures=[]}]
        //OK
    }
}

网络异常，图片无法展示
|

查看数据库发现已经被更新成功

网络异常，图片无法展示
|

删除文档

package com.wyh;
import com.alibaba.fastjson.JSON;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.wyh.config.ElasticSearchClientConfig;
import com.wyh.entity.User;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.Request;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;
import org.elasticsearch.client.indices.GetIndexRequest;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
import org.elasticsearch.search.suggest.completion.RegexOptions;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.TestPropertySource;
import javax.annotation.Resource;
import java.io.IOException;
/**
 * 测试es7.6.1 高级客户端API操作
**/
@SpringBootTest
class WyhApplicationTests {
//注入bean
    @Resource
private RestHighLevelClient client;
//删除文档信息
    @Test
void testDeleteDocument() throws IOException {
//更新请求
        DeleteRequest deleteRequest = new DeleteRequest("wei_index","1");
//超时时间 1s
        deleteRequest.timeout("1s");
        DeleteResponse deleteResponse = client.delete(deleteRequest, RequestOptions.DEFAULT);
        System.out.println(deleteResponse);
//DeleteResponse[index=wei_index,type=_doc,id=1,version=3,result=deleted,shards=ShardInfo{total=2, successful=1, failures=[]}]
    }
}

查看索引库发现文档已经被删除

网络异常，图片无法展示
|

批量插入

package com.wyh;
import com.alibaba.fastjson.JSON;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.wyh.config.ElasticSearchClientConfig;
import com.wyh.entity.User;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.Request;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;
import org.elasticsearch.client.indices.GetIndexRequest;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
import org.elasticsearch.search.suggest.completion.RegexOptions;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.TestPropertySource;
import javax.annotation.Resource;
import java.io.IOException;
import java.util.ArrayList;
/**
 * 测试es7.6.1 高级客户端API操作
**/
@SpringBootTest
class WyhApplicationTests {
//注入bean
    @Resource
private RestHighLevelClient client;
//特殊的 ElasticSearch批量插入数据
    @Test
void testBatchInsert() throws IOException {
        BulkRequest bulkRequest = new BulkRequest();
//设置过期时间
        bulkRequest.timeout("10s");
//泛型为User的list
        ArrayList<User> userArrayList = new ArrayList<>();
//添加用户信息
        userArrayList.add(new User("魏一鹤1",14));
        userArrayList.add(new User("魏一鹤2",14));
        userArrayList.add(new User("魏一鹤3",14));
        userArrayList.add(new User("魏一鹤4",14));
        userArrayList.add(new User("魏一鹤5",14));
//批量添加数据
        for (int i = 0; i < userArrayList.size(); i++) {
//批量删除或者插入就在这里修改对应的请求即可
            bulkRequest.add(
//插入那个库
                    new IndexRequest("wei_index")
//id
                    .id(""+(i+1))
//json数据源
                    .source(JSON.toJSONString(userArrayList.get(i)),XContentType.JSON)
            );
        }
//执行批量插入请求并且获取相应
        BulkResponse bulk = client.bulk(bulkRequest, RequestOptions.DEFAULT);
//是否执行失败 如果是false就没有失败
        System.out.println(bulk.hasFailures());//false
    }
}

查看库里发现已经插入成功

网络异常，图片无法展示
|

如果指名id会随机生成很长的id，防止数据重复

网络异常，图片无法展示
|

网络异常，图片无法展示
|

文章标签：
检索分析服务 Elasticsearch版
索引
API
数据库
关键词：
API文档
API操作
API批量插入
API更新
文档API操作
相关实践学习
使用阿里云Elasticsearch体验信息检索加速
通过创建登录阿里云Elasticsearch集群，使用DataWorks将MySQL数据同步至Elasticsearch，体验多条件检索效果，简单展示数据同步和信息检索加速的过程和操作。
ElasticSearch 入门精讲
ElasticSearch是一个开源的、基于Lucene的、分布式、高扩展、高实时的搜索与数据分析引擎。根据DB-Engines的排名显示，Elasticsearch是最受欢迎的企业搜索引擎，其次是Apache Solr（也是基于Lucene）。 ElasticSearch的实现原理主要分为以下几个步骤： 用户将数据提交到Elastic Search 数据库中 通过分词控制器去将对应的语句分词，将其权重和分词结果一并存入数据 当用户搜索数据时候，再根据权重将结果排名、打分 将返回结果呈现给用户 Elasticsearch可以用于搜索各种文档。它提供可扩展的搜索，具有接近实时的搜索，并支持多租户。
游客5m6wdh6ebwgya
目录
相关文章
三分钟热度的鱼
|
22天前
|
敏捷开发 测试技术 API
云效产品使用常见问题之代码仓库不支持API文档如何解决
云效作为一款全面覆盖研发全生命周期管理的云端效能平台，致力于帮助企业实现高效协同、敏捷研发和持续交付。本合集收集整理了用户在使用云效过程中遇到的常见问题，问题涉及项目创建与管理、需求规划与迭代、代码托管与版本控制、自动化测试、持续集成与发布等方面。
三分钟热度的鱼
24 1
IT胡图图
|
2月前
|
Java API Maven
HDFS的API操作
HDFS的API操作
IT胡图图
31 0
懒大王敲代码
|
2月前
|
数据可视化 Linux API
如何在Linux使用docker部署Swagger Editor并实现无公网IP远程协同编辑API文档
如何在Linux使用docker部署Swagger Editor并实现无公网IP远程协同编辑API文档
懒大王敲代码
53 0
cuicuicuic
|
14天前
|
SQL JSON DataWorks
DataWorks操作报错合集之DataWorks报错显示API不存在，但这个API应该是有的，如何解决
DataWorks是阿里云提供的一站式大数据开发与治理平台，支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中，可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
cuicuicuic
32 2
游客emrqsofjr3jl2
|
7天前
|
测试技术 API 开发工具
📑教你如何编写一份 API 文档
API 文档是开发者理解和使用API的关键，它提供详细的说明、代码示例和调用过程，帮助创建无缝集成。好的API文档能提升开发人员体验，减少上手时间和维护成本，同时促进产品迭代。API有面向团队、合作伙伴和最终用户三种类型。编写文档时要考虑受众，提供清晰的概述、教程、认证信息、端点定义、状态码和错误码示例。维护更新与API同步的文档至关重要，遵循通俗语言、参考文档、示例和专人负责等最佳实践，确保全面性。GitHub、Twilio和Dropbox的API文档是良好示例。
游客emrqsofjr3jl2
12 0
xin在这
|
13天前
|
分布式计算 DataWorks 关系型数据库
DataWorks操作报错合集之在DataWorks同步数据时，遇到乱码问题，该怎么解决（rest api数据源）
DataWorks是阿里云提供的一站式大数据开发与治理平台，支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中，可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
xin在这
22 0
cuicuicuic
|
14天前
|
存储 缓存 运维
DataWorks操作报错合集之DataWorks根据api，调用查询文件列表接口报错如何解决
DataWorks是阿里云提供的一站式大数据开发与治理平台，支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中，可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
cuicuicuic
23 1
漫走云雾
|
18天前
|
前端开发 Java 测试技术
IDEA 版 API 接口神器来了，一键生成文档，贼香！
IDEA 版 API 接口神器来了，一键生成文档，贼香！
漫走云雾
55 0
请回答1024
|
18天前
|
XML API 数据格式
工作流JBPM操作API组任务
工作流JBPM操作API组任务
请回答1024
20 1
请回答1024
|
18天前
|
API 数据库
工作流JBPM操作API办理任务&流程变量
工作流JBPM操作API办理任务&流程变量
请回答1024
16 0

热门文章

最新文章

  • 1
    GPT-4 API 接口调用及价格分析
  • 2
    HBase API 操作范例
  • 3
    【翻译】在Visual Studio中使用Asp.Net Core MVC创建你的第一个Web API应用（一）
  • 4
    Java中REST API使用示例——基于云平台+云服务打造自己的在线翻译工具
  • 5
    Web APi之过滤器创建过程原理解析【一】（十）
  • 6
    Arcgis api For silverlight 加载高德地图
  • 7
    android 中文api （63） —— SimpleAdapter.ViewBinder
  • 8
    jQuery EasyUI API 中文文档 - 菜单按钮（MenuButton）
  • 9
    jQuery EasyUI API 中文文档 - Documentation 文档
  • 10
    企业微信开发（二）：API对接及Demo程序
  • 1
    常用JavaScript 数组 API大全
    37
  • 2
    JavaScript循环遍历常用的7种方法以及常用的数组 API
    37
  • 3
    解释如何在 Python 中实现 Web 服务（RESTful API）。
    31
  • 4
    Java 8新特性之Lambda表达式和Stream API
    25
  • 5
    视觉智能平台常见问题之抠人脸的api如何解决
    33
  • 6
    亚马逊API接口获取商品详情的全面指南
    106
  • 7
    从API到Agent：万字长文洞悉LangChain工程化设计
    126
  • 8
    如何在Linux使用docker部署Swagger Editor并实现无公网IP远程协同编辑API文档
    53
  • 9
    虾皮Shopee根据ID取商品详情API
    39
  • 10
    谷歌发布MediaPipe LLM Inference API，28亿参数模型本地跑
    99

    • 相关课程

    更多
  • 体验-K8S API 基础及Pod 基本应用

    • 相关电子书

    更多
  • CUDA MATH API
  • API PLAYBOOK
  • 传统企业的“+互联网”-API服务在京东方的实践

    • 相关实验场景

    更多
  • 快速体验智能体API应用
  • 使用交互方式实现数据查询、插入、修改和删除操作
  • 使用Count功能批量创建资源
  • Elasticsearch Java API Client 开发
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）