《七牛云》专题
-
无法建立垂直。云环境中垂直柱之间的x群集
无法建立垂直。云环境中垂直柱之间的x群集 我在配置vert时遇到问题。x eventbus群集在私有云环境中。 在实验室测试中，我尝试使用Hazelcast集群管理器制作两个垂直点来建立一个集群，每个垂直点都在您自己的容器中运行。 问题很可能是由于配置错误引起的，但我无法找到它。在这个云上，不可能进行多播调用，那么我使用的是TCP IP发现策略。 最初的计划是制作一个“labatf api”垂直链
-
谷歌云数据流如何使用apache束从BigQuery读取？
结果如何在工作人员之间分配？是使用查询结果创建一个表，工作人员从中读取页面，还是每个工作人员运行查询并读取不同的页面或。。。怎样
-
添加Google云消息模块后Gradle同步失败
我正在开发一个android应用程序，我在android Studio上遇到了一个问题 null
-
Google云数据流-Apache Beam-管道关闭挂钩
想知道是否有某种“钩子”来放置apache beam管道关闭时将执行的一段代码（无论出于何种原因-崩溃、取消） 每次数据流停止时，我都需要删除pubsub主题的订阅。
-
使用beam时，“ValueError：云发布/订阅当前仅可用于流式管道”。io。批处理模式下的WriteToPubSub（）
我正在从查找中读取一些客户记录并将其写入bigquery表，然后从同一个表中读取一些必需的数据栏并尝试将该数据（Json）作为消息推送到pubsub中，在批处理模式下使用数据流管道。但是收到错误：“ValueError：Cloud Pub/Sub目前仅可用于流媒体管道”。 我想在数据流管道的批处理模式中使用PubSub
-
Google云平台：将数据从发布/订阅累积到云存储中的文件，无需数据流
我试图弄清楚GCP上是否有一项服务，允许使用发布/订阅的流，并将累积的数据转储/批处理到云存储中的文件中（例如，每X分钟一次）。我知道这可以通过Dataflow实现，但如果有现成的解决方案，我会寻找更多的解决方案。 例如，这是可以使用AWS Kinesis Firehose进行的操作—纯粹在配置级别—可以告诉AWS定期或在累积数据达到一定大小时将流中累积的任何内容转储到S3上的文件。 这样做的原因
-
云发布/订阅和云数据流将工作者修复到主题
我有一个谷歌云发布/订阅和云数据流处理架构，我需要有保证的消息排序。是否可以设置订阅消息流，以便每个主题的数据流工作线程是固定的，因此消息通过相同的数据流工作线程路由，因此应该实现消息排序。 谢谢
-
使用Google云数据流SDK读取流数据
我正在开发一个物联网应用程序，需要从PubSub主题读取流数据。我想使用Google云数据流SDK读取这些数据。我正在使用Java 1.8 我正在使用谷歌云平台的试用版。当我使用PubSubIO时。Read方法读取流数据时，我在日志文件中发现错误，我的项目没有足够的CPU配额来运行应用程序。 所以我想使用谷歌云数据流SDK读取流数据。 请有人告诉我在哪里可以找到使用Google Cloud Dat
-
谷歌云数据流：使用DirectPipelineRunner（本地作业）访问管道中的谷歌云发布/订阅？
我已经使用Google云数据流SDK编写了一个流式管道，但我想在本地测试我的管道。我的管道从Google Pub/Sub获取输入数据。 是否可以使用DirectPipelineRunner（本地执行，而不是在Google云中）运行访问发布/订阅（pubsubIO）的作业？ 我在以普通用户帐户登录时遇到权限问题。我是项目的所有者，我正在尝试访问发布/子主题。
-
将注释与Spring云断路器-Resilience4j一起使用
是否可以通过注释在Spring Cloud Circuit Breaker上使用Resilience4j？我找不到任何关于它的留档，只有关于通过代码使用弹性4j的示例
-
通过在谷歌云数据流中使用Python SDK推断模式来读写avro文件-Apache Beam
问题：我正在尝试创建一个云数据流管道，该管道使用Python SDK从Google云存储读取Avro文件，进行一些处理并在Google云存储上写回Avro文件。在查看ApacheBeam网站上提供的一些示例后，我尝试运行以下代码。我使用了和函数。我试图实现的是读取一个Avro文件并使用Dataflow写入同一个Avro文件，但它给了我以下警告，并且没有输出Avro文件。 警告/错误： 代码： 编辑
-
Spring云蒸汽注册表和Avro模式文件
我已经设置了Spring Cloud Stream中提供的Spring Avro模式注册表，以便在RabbitMQ中使用。我看到的大多数示例都使用Maven Avro插件从模式资源文件生成Java类。然后在架构注册表中注册架构文件。我的理解是，此注册表允许消息仅通过对已注册架构的引用进行SERDE，而不是在消息中包含整个架构。我不明白的是，在设计时，这些模式文件是如何在所有服务之间分发的，以生成J
-
Spring云流Avro
我无法使用功能供应商发送Avro消息。SCSt尝试将消息作为JSON发送，但失败。有人能指出是否需要任何其他配置吗？ 这是供应商的功能bean 和配置
-
如何基于特定批处理作业定义spring批处理云任务
我们目前正在将一个复杂的spring boot batch+admin UI系统迁移到一个spring-cloud-task基础设施中，该基础设施将被管理云数据流。 作为POC的第一阶段，我们必须能够将所有Spring批处理作业打包在同一个部署JAR下，并且能够使用自定义作业参数一个接一个地运行它们，并且支持某种REST API远程执行作业/任务。 我们删除了所有spring-batch管理依赖项
-
“发布/订阅到云扳手”是否有任何GCP数据流模板
我正在尝试找出是否有任何GCP数据流模板可用于使用“Pub/Sub to Cloud Spanner”进行数据摄取。我发现已经有一个默认的GCP数据流模板可用于示例-“Cloud Pub/Sub to BigQuery”。所以，我有兴趣看看我是否可以在流或批处理模式下对扳手进行数据摄取，以及行为会如何