使用Spring Boot对ElasticSearch/AWS进行Java API健康检查

Question

我是我的公司的软件工程实习生，我们使用AWS（Amazon Web Services)、EC2/ECS/Fargate/NLB，我的任务是为我们的Elasticsearch服务添加一个健康检查监视器到我们的后端API中，我们用Java编写了这个后端API（使用Spring Boot/MVC/Maven）。我按照这里的指南使用Springs Actuctor来进行健康检查监视器，它非常简单：https://www.amitph.com/custom-healt-check-spring-boot-actuctor/

您所要做的就是在SpringBoot中实现HealthIndicator接口，下面是我用基本代码创建的IndexExists类：

@Component
public class IndexExists implements HealthIndicator {
    private final ESClient esClient;
    private static final Logger LOGGER = LoggerFactory.getLogger(IndexExists.class);


    @Autowired
    public IndexExists(ESClient esClient) {
        this.esClient = esClient;
    }

    @Override
    public Health health() {
        try {
            if (!esClient.hasIndex(Indices.INDEX_ASSETS)) {
                return Health.down().withDetail("index", Indices.INDEX_ASSETS + " index does not exist").build();
            }
        } catch (IOException e) {
            LOGGER.error("Error checking if Elasticsearch index {} exists , with exception", Indices.INDEX_ASSETS,  e);
        }
        return Health.up().withDetail("index", Indices.INDEX_ASSETS + " exists").build();
    }
}

我知道这是一个很长的机会，但我希望有AWS/ElasticSearch经验的人可能设置一个健康监视器endpoint之前，遇到这样的问题....如果有人需要我的更多信息，我很乐意帮忙。这是我实习时的第一个用户故事，我不想失败。我已经写好了所有的代码，而且看起来还不错，但是我遇到了AWS的网络/连接问题，除非我在配置设置（application.yml）中有一个我遗漏的小错误。

Answer 1

首先，实际上我不会在弹性搜索的应用程序中做健康检查，AWS有办法监控弹性搜索，集群健康等。如果你的状态是红色的，那意味着他们至少存在一个红色索引。所有的索引都应该是绿色的，如果有一个红色的索引，你需要从快照恢复它。您的应用程序只需假设es一直都是健康的。如果调用失败，请使用log.error记录它。您可以在Kibanna创建一个仪表板，它可以监视对ES的这些调用，以查看这一切都是如何进行的。

至于连接到es，这取决于您使用的是公共endpoint还是VPCendpoint。

VPCendpoint如果使用VPCendpoint，您需要具有正确的安全组配置，因此连接到ES群集的安全组需要允许来自应用程序的流量。令人困惑的是，您在es中看到了日志，但它们很可能来自logstash实例，因此您的应用程序连接到的是logstash，而不是es。检查应用程序的安全组是否包含在ES集群的安全组的允许部分中。

公共

如果它是公共的ES，那么您需要在应用程序上具有正确的IAM权限才能连接。检查应用程序的角色是否可以访问es:{TODO}对于您的域，您可以联机查找策略。