当前位置: 首页 > 知识库问答 >
问题:

将logstash、配置服务器和eureka与Spring Cloud任务和数据流一起使用

邹英光
2023-03-14

我们有一个现有的带有logstash、config和eureka服务器的微服务环境。我们现在正在设置Spring Cloud Dataflow(库伯内特斯)环境(主要最初用于运行任务/批处理作业)。

理想情况下,我们希望任务通过标准Spring Boot配置(注释等)使用现有的logstash、config和eureka服务器来支持以下场景:

Logstash:当任务运行时,其日志输出到Logstash,并可从Kibana查看

配置服务器:支持更改任务的配置属性。例如,可以通过更改配置服务器上的值来调整定期任务的配置,下次任务运行时,它将使用新值。我的理解是,配置服务器属性将覆盖任务定义中的属性,而任务定义将覆盖内部应用程序中的属性。属性。

Eureka:每个任务都会在Eureka中注册。这主要是因为我们的任务暴露了web执行器endpoint,然后我们可以使用Spring Boot Admin(它可以通过eureka发现服务)在任务运行时访问执行器endpoint和信息。(我们的一些任务可能需要数小时才能运行,这将使我们能够监视它们,调整日志记录等)

这是一种合理的方法吗?或者这里是否有任何潜在的问题需要注意(例如eureka的短期任务)。我在现有的spring云数据流或spring云任务文档中找不到对此的任何讨论。

共有1个答案

鲁明知
2023-03-14

您可以尝试使用logstash logback编码器与ELK堆栈进行SCDF集成。它适用于我们的SCDF在纱线流应用中。

配置服务器应该适用于任何Spring Boot应用程序。

 类似资料:
  • 我目前正在尝试学习微服务架构。我一直在尝试开发一个 Spring 启动应用程序。我刚刚在我的应用程序中实现了配置服务器。在我实现配置服务器之前,liquibase 在这些属性上工作正常。 实现后,我的服务没有找到db.changelog-master.xml文件。db.changelog目录在我的服务资源下。我应该如何更改“更改日志”属性?

  • spring webclient无法从eureka服务器的服务实例名称中检索实际主机,出现以下异常: Spring启动版本:2.2.3。BUILD-SNAPSHOT

  • 我连接RabbitMQ与斯普林云配置: 2.设置RabbitTemplate.set强制性(true)和setConfirmCallback(): 3.将消息发送到队列以调用发布者确认并打印日志。 但出版商确认没有工作。日志尚未打印。无论真假,日志都不应该缺席。

  • 但这样我就无法访问eureka仪表盘,只是使用默认配置: 在我的客户端中,同样的事情也发生了,我不能指向另一个不同于默认(localhost:8761)的eureka服务器,请参阅我的配置: 查看客户端日志,我得到了以下内容: 无论我在客户端配置什么端口或主机,都要尽量达到默认值。 重要提示:我在以下版本中使用eureka:https://mvnrepository.com/artifact/or

  • 我试图了解运行批处理任务时通过Spring Cloud数据流WRT数据源配置的预期行为。 Spring批处理数据库表(Batch\u JOB\u EXECUTION等)是否在SCDF数据库本身中?当通过SCDF启动任务时,似乎发生了一些神奇的事情,它在SCDF数据库中创建了这些表,并似乎在使用它们。它似乎正在将SCDF数据源注入我的应用程序? 我目前在localhost服务器版本2.0.1上运行。

  • 根据这里和那里的文档,我设法设置了一个授权服务器,该服务器提供使用非对称密钥签名的JWT访问令牌,资源服务器使用公钥的本地副本在本地验证这些令牌。到现在为止,一直都还不错。 我的最终目标是让资源服务器在授权服务器上使用JWKSendpoint,并使用JWT中的“kid”头在JWKS中查找正确的密钥并在本地进行验证,从而支持密钥轮换。我发现了如何使授权服务器公开JWKSendpoint,以及如何为资