« 启动快照生命周期管理 解决损坏的存储库 »
Elastic 文档 ›Elasticsearch 指南 [8.17] ›问题排查

从快照恢复

编辑

从快照恢复

编辑

Elasticsearch 使用快照在集群外部存储数据的副本。您可以还原快照以恢复集群中没有分片副本的索引和数据流。如果数据（索引或数据流）被删除，或者集群成员发生更改，并且系统中当前节点不再包含数据的副本，则可能会发生这种情况。

要恢复丢失的数据，您需要拥有受影响的索引和数据流的备份，该备份对于您的用例来说足够新。请在确认这一点之后再继续操作。

为了恢复缺少数据的索引和数据流

使用 Kibana

  1. 登录到 Elastic Cloud 控制台。

  2. 在 Elasticsearch Service 面板上，单击您的部署名称。

    如果您的部署名称被禁用，则您的 Kibana 实例可能不健康，在这种情况下，请联系 Elastic 支持。如果您的部署不包含 Kibana，您只需先启用它。

  3. 打开部署的侧边导航菜单（位于左上角的 Elastic 徽标下），然后转到 Dev Tools > 控制台。

    Kibana Console

  4. 要使用 cat indices API 查看受影响的索引。

    resp = client.cat.indices(
    v=True,
    health="red",
    h="index,status,health",
)
print(resp)
    response = client.cat.indices(
  v: true,
  health: 'red',
  h: 'index,status,health'
)
puts response
    const response = await client.cat.indices({
  v: "true",
  health: "red",
  h: "index,status,health",
});
console.log(response);
    GET _cat/indices?v&health=red&h=index,status,health

    响应将如下所示

    index                                status health
.ds-my-data-stream-2022.06.17-000001 open   red
kibana_sample_data_flights           open   red

    上面索引的 red 健康状态表明这些索引缺少主分片，这意味着它们缺少数据。

  5. 为了恢复数据，我们需要找到一个包含这两个索引的快照。要找到这样的快照，请使用 get snapshot API。

    resp = client.snapshot.get(
    repository="my_repository",
    snapshot="*",
    verbose=False,
)
print(resp)
    response = client.snapshot.get(
  repository: 'my_repository',
  snapshot: '*',
  verbose: false
)
puts response
    const response = await client.snapshot.get({
  repository: "my_repository",
  snapshot: "*",
  verbose: "false",
});
console.log(response);
    GET _snapshot/my_repository/*?verbose=false

    响应将如下所示

    {
  "snapshots" : [
    {
      "snapshot" : "snapshot-20200617",                                     
      "uuid" : "dZyPs1HyTwS-cnKdH08EPg",
      "repository" : "my_repository",                                       
      "indices" : [                                                         
        ".apm-agent-configuration",
        ".apm-custom-link",
        ".ds-ilm-history-5-2022.06.17-000001",
        ".ds-my-data-stream-2022.06.17-000001",
        ".geoip_databases",
        ".kibana-event-log-8.2.2-000001",
        ".kibana_8.2.2_001",
        ".kibana_task_manager_8.2.2_001",
        "kibana_sample_data_ecommerce",
        "kibana_sample_data_flights",
        "kibana_sample_data_logs"
      ],
      "data_streams" : [ ],
      "state" : "SUCCESS"                                                     
    }
  ],
  "total" : 1,
  "remaining" : 0
}

    快照的名称。

    快照的存储库。

    快照中备份的索引。

    快照是否成功。
  6. 快照 snapshot-20200617 包含我们要恢复的两个索引。您可能拥有多个快照，可以从中恢复目标索引。选择最新的快照。

  7. 现在我们找到了快照，我们将继续进行数据流准备以恢复丢失的数据。我们将检查索引元数据，以查看是否有任何索引是数据流的一部分

    resp = client.indices.get(
    index="kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001",
    features="settings",
    flat_settings=True,
)
print(resp)
    response = client.indices.get(
  index: 'kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001',
  features: 'settings',
  flat_settings: true
)
puts response
    const response = await client.indices.get({
  index: "kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001",
  features: "settings",
  flat_settings: "true",
});
console.log(response);
    GET kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001?features=settings&flat_settings

    响应将如下所示

    {
  ".ds-my-data-stream-2022.06.17-000001" : {                                
    "aliases" : { },
    "mappings" : { },
    "settings" : {                                                          
      "index.creation_date" : "1658406121699",
      "index.hidden" : "true",
      "index.lifecycle.name" : "my-lifecycle-policy",
      "index.number_of_replicas" : "1",
      "index.number_of_shards" : "1",
      "index.provided_name" : ".ds-my-data-stream-2022.06.17-000001",
      "index.routing.allocation.include._tier_preference" : "data_hot",
      "index.uuid" : "HmlFXp6VSu2XbQ-O3hVrwQ",
      "index.version.created" : "8020299"
    },
    "data_stream" : "my-data-stream"                                        
  },
  "kibana_sample_data_flights" : {                                          
    "aliases" : { },
    "mappings" : { },
    "settings" : {
      "index.creation_date" : "1655121541454",
      "index.number_of_replicas" : "0",
      "index.number_of_shards" : "1",
      "index.provided_name" : "kibana_sample_data_flights",
      "index.routing.allocation.include._tier_preference" : "data_content",
      "index.uuid" : "jMOlwKPPSzSraeeBWyuoDA",
      "index.version.created" : "8020299"
    }
  }
}

    索引的名称。

    此索引的设置，其中包含我们要查找的元数据。

    这表示此索引是数据流的一部分，并显示数据流名称。

    我们请求的另一个索引的名称。

    上面的响应显示 kibana_sample_data_flights 不是数据流的一部分，因为它在设置中没有名为 data_stream 的字段。

    相反，.ds-my-data-stream-2022.06.17-000001 是名为 my-data-stream 的数据流的一部分。当您找到像这样的属于数据流的索引时，您需要检查是否仍在索引数据。您可以通过检查 settings 来查看，如果您可以找到此属性："index.lifecycle.indexing_complete" : "true"，则表示此索引中的索引已完成，您可以继续下一步。

    如果 index.lifecycle.indexing_complete 不存在或配置为 false，您需要滚动数据流，以便您可以恢复丢失的数据，而不会阻止新数据的摄取。以下命令将实现此目的。

    resp = client.indices.rollover(
    alias="my-data-stream",
)
print(resp)
    response = client.indices.rollover(
  alias: 'my-data-stream'
)
puts response
    const response = await client.indices.rollover({
  alias: "my-data-stream",
});
console.log(response);
    POST my-data-stream/_rollover

  8. 现在数据流准备已完成，我们将使用 close indices API 关闭目标索引。

    resp = client.indices.close(
    index="kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001",
)
print(resp)
    response = client.indices.close(
  index: 'kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001'
)
puts response
    const response = await client.indices.close({
  index: "kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001",
});
console.log(response);
    POST kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001/_close

    您可以使用 cat indices API 确认它们已关闭。

    resp = client.cat.indices(
    v=True,
    health="red",
    h="index,status,health",
)
print(resp)
    response = client.cat.indices(
  v: true,
  health: 'red',
  h: 'index,status,health'
)
puts response
    const response = await client.cat.indices({
  v: "true",
  health: "red",
  h: "index,status,health",
});
console.log(response);
    GET _cat/indices?v&health=red&h=index,status,health

    响应将如下所示

    index                                status health
.ds-my-data-stream-2022.06.17-000001 close   red
kibana_sample_data_flights           close   red

  9. 索引已关闭，现在我们可以使用 restore snapshot API 从快照恢复它们，而不会造成任何复杂情况

    resp = client.snapshot.restore(
    repository="my_repository",
    snapshot="snapshot-20200617",
    indices="kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001",
    include_aliases=True,
)
print(resp)
    response = client.snapshot.restore(
  repository: 'my_repository',
  snapshot: 'snapshot-20200617',
  body: {
    indices: 'kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001',
    include_aliases: true
  }
)
puts response
    const response = await client.snapshot.restore({
  repository: "my_repository",
  snapshot: "snapshot-20200617",
  indices: "kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001",
  include_aliases: true,
});
console.log(response);
    POST _snapshot/my_repository/snapshot-20200617/_restore
{
  "indices": "kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001", 
  "include_aliases": true                                                       
}

    要恢复的索引。

    我们还希望恢复别名。

    如果需要恢复任何功能状态，我们需要使用 feature_states 字段指定它们，并且属于我们恢复的功能状态的索引不得在 indices 下指定。Health API 返回需要从快照恢复诊断中恢复的 indices 和 feature_states。例如：

    resp = client.snapshot.restore(
    repository="my_repository",
    snapshot="snapshot-20200617",
    feature_states=[
        "geoip"
    ],
    indices="kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001",
    include_aliases=True,
)
print(resp)
    response = client.snapshot.restore(
  repository: 'my_repository',
  snapshot: 'snapshot-20200617',
  body: {
    feature_states: [
      'geoip'
    ],
    indices: 'kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001',
    include_aliases: true
  }
)
puts response
    const response = await client.snapshot.restore({
  repository: "my_repository",
  snapshot: "snapshot-20200617",
  feature_states: ["geoip"],
  indices: "kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001",
  include_aliases: true,
});
console.log(response);
    POST _snapshot/my_repository/snapshot-20200617/_restore
{
  "feature_states": [ "geoip" ],
  "indices": "kibana_sample_data_flights,.ds-my-data-stream-2022.06.17-000001",
  "include_aliases": true
}

  10. 最后，我们可以通过 cat indices API 验证索引的健康状态现在为 green。

    resp = client.cat.indices(
    v=True,
    index=".ds-my-data-stream-2022.06.17-000001,kibana_sample_data_flightsh=index,status,health",
)
print(resp)
    response = client.cat.indices(
  v: true,
  index: '.ds-my-data-stream-2022.06.17-000001,kibana_sample_data_flightsh=index,status,health'
)
puts response
    const response = await client.cat.indices({
  v: "true",
  index:
    ".ds-my-data-stream-2022.06.17-000001,kibana_sample_data_flightsh=index,status,health",
});
console.log(response);
    GET _cat/indices?v&index=.ds-my-data-stream-2022.06.17-000001,kibana_sample_data_flightsh=index,status,health

    响应将如下所示

    index                                status health
.ds-my-data-stream-2022.06.17-000001 open   green
kibana_sample_data_flights           open   green

    正如我们在上面看到的，索引是 green 并且已打开。问题已解决。

有关创建和恢复快照的更多指导，请参阅本指南。

« 启动快照生命周期管理 解决损坏的存储库 »