news 2026/6/10 13:24:19

Opensearch数据迁移:CCR功能数据迁移完整操作指南(上)

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
Opensearch数据迁移:CCR功能数据迁移完整操作指南(上)

#作者:stackofumbrella

文章目录

  • 使用CCR功能迁移数据
    • 功能概述
    • 约束限制
    • 在主集群中创建索引
    • 从集群中执行启用CCR复制功能
    • 在主集群中写入测试数据
    • 在从集群中查看同步状态
    • 查看从集群中的同步数据
    • 关闭CCR功能
      • 查看远程集群信息
      • 删除远程集群配置信息

使用CCR功能迁移数据

功能概述

OpenSearch服务支持将数据复制到一个或多个OpenSearch集群,通过opensearch-cross-cluster-replication插件,以Replication方式从OpenSearch迁移数据,可实现集群数据迁移和灾备。创建OpenSearch跨集群复制后,主 OpenSearch集群上对索引的所有操作,包括创建、更新、删除文档等,都将复制到从集群节点上。

约束限制

跨集群复制期间,复制到从集群的索引仅可读。
跨集群复制期间,不能将从集群索引复制到主集群。
复制停止后,不支持重启复制。
在从集群中配置CCR,其中leader_cluster配置主机群的transport地址和端口

PUT _cluster/settings { "persistent": { "cluster": { "remote": { "leader_cluster": { "seeds": ["192.168.131.158:9301"] } } } } }

成功返回结果

在主集群中创建索引

PUT /test { "mappings": { "properties": { "main_data_type": { "type": "text", "fields": { "keyword": { "type": "keyword", "ignore_above": 256 } } } } } }

从集群中执行启用CCR复制功能

PUT /_plugins/_replication/test/_start?pretty { "leader_alias": "leader_cluster", "leader_index": "test", "use_roles":{ "leader_cluster_role": "all_access", "follower_cluster_role": "all_access" } }

在主集群中写入测试数据

POST /test/_doc { "name": "张三", "age": 30, "city": "北京" } POST /test/_doc { "name": "张3", "age": 32, "city": "男京" } POST /test/_doc { "name": "离你3", "age": 99, "city": "县城" }

在从集群中查看同步状态

获取索引复制的状态。可能的状态包括SYNCING(正在同步)、BOOTSTRAPING(正在引导)、PAUSED(已暂停)和REPLICATION NOT IN PROGRESS(复制未进行)。使用同步详情来衡量复制延迟。将此请求在从集群执行

GET /_plugins/_replication/test/_status

返回结果

查看从集群中的同步数据

GET test/_search { "query": { "match_all": {} } }

返回结果

到此CCR的复制功能已经完成

关闭CCR功能

暂停
暂停索引的复制,将此请求在从集群执行,如果复制暂停超过12小时,则无法恢复,必须停止CCR复制并删除复制索引,然后重新启动索引的复制

POST /_plugins/_replication/test/_pause {}

返回结果

停止复制
终止复制并将跟随复制的索引转换为标准索引,将此请求在从集群执行

POST /_plugins/_replication/test/_stop {}

返回结果

查看远程集群信息

GET /_remote/info

返回结果

删除远程集群配置信息

DELETE /_plugins/_replication/_autofollow { "leader_alias" : "leader_cluster", "name": "test" }

返回结果

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/6/6 8:55:07

JLink烧录器使用教程:STM32 Flash编程操作指南

JLink烧录实战全指南:从零掌握STM32 Flash编程核心技巧你有没有遇到过这种情况——代码改了几十遍,每次用串口ISP下载都要等十几秒,开发效率被卡得死死的?或者产线批量烧录时,原厂工具速度慢、稳定性差,良率…

作者头像 李华
网站建设 2026/6/10 11:35:58

实验一 Python开发环境语法基础

实验一 Python开发环境&语法基础一、实验基本原理运用Anaconda搭建的Jupyter notebook平台编写实例Python程序。二、实验目的1、熟悉Python集成开发系统背景。2、熟悉Jupyter Notebook开发环境。3、熟悉编写程序的基本过程。三、具体要求1、熟悉Python的基本语法&#xff0…

作者头像 李华
网站建设 2026/6/10 11:38:35

eide环境下GD32固件下载失败问题全面讲解

eIDE烧录GD32失败?从底层机制到实战排错的全链路技术拆解你有没有遇到过这样的场景:代码编译通过,接线看似没问题,点击“Download”按钮后却弹出一串红字——“Target Not Responding”、“Connection Failed”或干脆卡在“Connec…

作者头像 李华
网站建设 2026/6/9 21:23:16

深入 Yak 语言高级编程:异步并发与延迟执行实践

深入Yak语言高级编程:异步并发与延迟执行实践 前言 Yak语言作为一款面向网络安全领域的动态编程语言,凭借其轻量、高效的特性,在渗透测试、漏洞挖掘等场景中得到了广泛应用。对于安全从业者而言,编写高性能的自动化脚本往往需要依…

作者头像 李华
网站建设 2026/6/10 11:37:04

常用注解有哪些?(@Configuration, @Bean, @Autowired, @Value等)

Spring Boot 常用注解详解一、核心注解分类1. 配置类注解Configuration用途:声明一个类为配置类,相当于XML配置文件特点:会被CGLIB代理,确保Bean方法返回单例Configuration public class AppConfig {// 内部可以定义Bean方法 }Bea…

作者头像 李华
网站建设 2026/6/10 12:38:20

AI应用架构师从0到1:AI虚拟培训项目的团队协作与角色分工

AI应用架构师从0到1:AI虚拟培训项目的团队协作与角色分工 1. 引入与连接 1.1 引人入胜的开场 想象一下,在未来的职场中,新员工无需再在冗长的线下培训课堂中昏昏欲睡,而是戴上虚拟现实(VR)设备,瞬间置身于高度仿真的工作场景中,与栩栩如生的虚拟导师进行互动,接受定…

作者头像 李华