问题标签 [spring-cloud-gcp]

我想以编程方式设置数据源的密码，并且仍然使用 Spring GCP 和 Spring Data 的自动配置。

背景

我想将我的密码作为加密 blob 获取并通过 Google KMS 解密。我读到 spring gcp auto configuration 改变了DataSourcePropertiesbean 以应用 gcp secific 配置（https://docs.spring.io/spring-cloud-gcp/docs/1.0.0.RELEASE/reference/html/_spring_jdbc.html#_literal_datasource_literal_creation_flow） .

现在我想再次改变DataSourceProperties暴露的 Bean GcpCloudSqlAutoConfiguration。暴露DataSourceProperties如下不起作用，因为GcpCloudSqlAutoConfiguration那时不知道要采用哪个Bean：由spring boot自动配置或我的配置。但是我的应该应用在配置的最后一步。

我正在尝试使用 Spring Cloud GCP PubSub 与 PubSub 模拟器进行通信。

依赖：

我也有这个application.properties：

在开始集成测试以检查主题是否存在后，我收到此错误：

堆栈跟踪原因：

使用的代码：

我的搜索没有发现此代码不起作用的任何原因。

有小费吗？

我创建了简化的示例来重现我的实际问题。

我的示例从 google pub/sub 接受，记录它并将 ack 发送回Pub/Sub

配置：

通知处理程序：

确认处理程序：

当我发送第一条消息时，一切正常 - 我在日志中看到消息并且 ack 被发送到 pubsub。我还看到 gcp 订阅页面上未确认的消息数量为 0。

但是在几次成功的消息之后，我的应用程序只是停止接收消息。我浪费了很多时间来调试，我能够找到以下内容：

几个线程挂在网上：org.springframework.messaging.core.GenericMessagingTemplate.TemporaryReplyChannel#receive(long):314

线程转储：

我想这是一个原因，因为在 com.google.cloud.pubsub.v1.MessageDispatcher#processOutstandingMessage 内部：

该行：

已执行但deliverMessageTask 未由threadExecutor 执行。

在我看来，它看起来像是库中的一个错误，但它可能是库滥用。无论如何，我正在寻找任何解决方案/解决方法来避免这个问题。

库版本：

我使用：
spring-boot 2.2.0.RELEASE
springCloudVersion ="Greenwich.SR3"

附言

我知道我可以增加线程池大小，例如：

但我不认为这是一个好主意。

我正在尝试使用此 repo 中托管的示例代码。https://github.com/spring-cloud/spring-cloud-gcp/tree/master/spring-cloud-gcp-samples/spring-cloud-gcp-pubsub-binder-sample我希望应用程序使用来自现有订阅。但是活页夹总是尝试为新创建的主题创建一个新主题和一个新订阅。我需要设置哪些属性才能使活页夹从现有订阅中使用

我可以按实例名称查看 GCP 计费吗？（不是按类型）我正在尝试按实例名称过滤 GCP 计费，这可能吗？我只成功按 GCP Compute Engine 和实例类型（n1-standard）等过滤...

我正在尝试以编程方式将与 GCP 计算实例关联的 machineType 与相应的计费 SKU 匹配，但无法找到直接关联的密钥。例如，下面是 machineType API 的响应：

以下是来自 cloudbilling API 的相应 SKU：

计费 SKU 中似乎没有值为 n1-standard-32 的字段。我们如何将这两者联系在一起，就像这个页面看起来一样：https ://cloud.google.com/compute/pricing ？

我想使用Spring批处理在GCP Storage中写入csv文件，我可以看到我们可以在通过批处理创建CSV文件后上传文件，

但是有什么方法可以直接将文件从 Spring Batch 写入 GCP Storage

从我的应用程序中，我必须调用使用谷歌身份验证的外部 http 服务。当我从浏览器调用它时它可以工作。我发现它发生是因为我有 cookie 包含

所以我的cookie看起来像这样：

我尝试直接在我的 restTemplate 中设置这个 cookie，它可以正常工作，但我希望我必须根据某种凭据获取令牌。

您能否提供正确使用 GCP auth 的示例？如何更新令牌？基于什么？

我找到了如何读取/更新 GCP 存储桶中现有文件的绝佳示例：

但我找不到如何使用 spring gloud GCP 将新文件上传到 GCP 存储桶的方法。

我怎样才能实现它？

我正在尝试在 GAE 上启动一个简单的 Java (Maven) Spring Boot 应用程序，该应用程序与 PostrgreSql 服务器（也在云平台上）进行通信，但是我一直遇到缺少的依赖项。

我的 pom 中有这些依赖项：

但是，每当我将应用程序部署到 GAE 和 FlyWay 时，都会抛出以下内容：

我主要在这里遵循 Baeldung 教程：https ://www.baeldung.com/spring-boot-google-app-engine 。

然后我找到了这个答案：AppEngine ClassNotFoundException: com.google.appengine.api.datastore.DatastoreServiceFactory 这导致我添加了 appengine 依赖项：

然后抛出：

然后导致我添加客户端依赖项..等等..等等..

我的完整依赖集现在是：

那..又回到了上面的异常：

所以这可能是一个依赖问题，但我找不到任何关于需要添加哪些依赖项才能让简单的 Spring Boot 应用程序运行到 PostgreSQL 服务器的文档。

我要认输了……不过可能是睡眠不足

我正在使用 pub sub 与 spring boot 的集成，我的配置类如下所示：

所以现在，我只调用了 sendToPubSub 方法，该方法将有效负载从我的应用程序添加到主题中，如下所示：

上面的代码仅适用于我从应用程序属性文件加载的一个主题。

但是现在我想让我的主题名称动态添加到messageSender中，如何做到这一点。