› › ›

Восстановление после сбоя, когда кластер clusterA возвращается

Когда clusterA возвращается, clusterB становится новым лидером, а clusterA — последователем.

Настройте удалённый кластер clusterB на clusterA.

resp = client.cluster.put_settings(
    persistent={
        "cluster": {
            "remote": {
                "clusterB": {
                    "mode": "proxy",
                    "skip_unavailable": "true",
                    "server_name": "clusterb.es.region-b.gcp.elastic-cloud.com",
                    "proxy_socket_connections": "18",
                    "proxy_address": "clusterb.es.region-b.gcp.elastic-cloud.com:9400"
                }
            }
        }
    },
)
print(resp)

response = client.cluster.put_settings(
  body: {
    persistent: {
      cluster: {
        remote: {
          "clusterB": {
            mode: 'proxy',
            skip_unavailable: 'true',
            server_name: 'clusterb.es.region-b.gcp.elastic-cloud.com',
            proxy_socket_connections: '18',
            proxy_address: 'clusterb.es.region-b.gcp.elastic-cloud.com:9400'
          }
        }
      }
    }
  }
)
puts response

const response = await client.cluster.putSettings({
  persistent: {
    cluster: {
      remote: {
        clusterB: {
          mode: "proxy",
          skip_unavailable: "true",
          server_name: "clusterb.es.region-b.gcp.elastic-cloud.com",
          proxy_socket_connections: "18",
          proxy_address: "clusterb.es.region-b.gcp.elastic-cloud.com:9400",
        },
      },
    },
  },
});
console.log(response);

### On clusterA ###
PUT _cluster/settings
{
  "persistent": {
    "cluster": {
      "remote": {
        "clusterB": {
          "mode": "proxy",
          "skip_unavailable": "true",
          "server_name": "clusterb.es.region-b.gcp.elastic-cloud.com",
          "proxy_socket_connections": "18",
          "proxy_address": "clusterb.es.region-b.gcp.elastic-cloud.com:9400"
        }
      }
    }
  }
}

Существующие данные необходимо удалить, прежде чем можно будет превратить любой индекс в последователя. Убедитесь, что самые актуальные данные доступны в clusterB до удаления любых индексов в clusterA.
```
resp = client.indices.delete(
    index="kibana_sample_data_ecommerce",
)
print(resp)
```
```
response = client.indices.delete(
  index: 'kibana_sample_data_ecommerce'
)
puts response
```
```
const response = await client.indices.delete({
  index: "kibana_sample_data_ecommerce",
});
console.log(response);
```
```
### On clusterA ###
DELETE kibana_sample_data_ecommerce
```

Создайте индекс-последователь в clusterA, который теперь будет следовать за индексом-лидером в clusterB.

resp = client.ccr.follow(
    index="kibana_sample_data_ecommerce",
    wait_for_active_shards="1",
    remote_cluster="clusterB",
    leader_index="kibana_sample_data_ecommerce2",
)
print(resp)

const response = await client.ccr.follow({
  index: "kibana_sample_data_ecommerce",
  wait_for_active_shards: 1,
  remote_cluster: "clusterB",
  leader_index: "kibana_sample_data_ecommerce2",
});
console.log(response);

### On clusterA ###
PUT /kibana_sample_data_ecommerce/_ccr/follow?wait_for_active_shards=1
{
  "remote_cluster": "clusterB",
  "leader_index": "kibana_sample_data_ecommerce2"
}

Индекс в последовательном кластере теперь содержит обновлённые документы.
```
resp = client.search(
    index="kibana_sample_data_ecommerce",
    q="kimchy",
)
print(resp)
```
```
response = client.search(
  index: 'kibana_sample_data_ecommerce',
  q: 'kimchy'
)
puts response
```
```
const response = await client.search({
  index: "kibana_sample_data_ecommerce",
  q: "kimchy",
});
console.log(response);
```
```
### On clusterA ###
GET kibana_sample_data_ecommerce/_search?q=kimchy
```
Если мягкое удаление будет объединёно до момента репликации в последователя, процесс завершится неудачей из-за неполной истории на лидере. См. index.soft_deletes.retention_lease.period для получения дополнительных сведений.

© 2023-2025 Elasticsearch
As of September 2024, Elasticsearch is available under a choice of three licenses: the Server Side Public License (SSPL), the Elastic License, or the AGPLv3 (OSI approved).
Elasticsearch and the Elasticsearch logo are trademarks of Elasticsearch B.V., registered in the U.S. and in other countries.
https://www.elastic.co/guide/en/elasticsearch/reference/8.17/_failback_when_clustera_comes_back.html