具有以下简单代码： public static class Sink extends com.google.cloud.dataflow.sdk.io.Sinksink;
this.sink = sink;
}) at com.<e
浏览 7提问于2016-11-02得票数 1
回答已采纳
extends com.google.cloud.dataflow.sdk.io.Sink<ZipInputStream> {
private static final long serialVersionUID类型提供编码器:无法提供ProtoCoder，因为java.util.zip.ZipInputStream不是com.google.protobuf.Message的子类；com.google.cloud.dataflow.sdk.coders.Serial
浏览 3提问于2016-10-28得票数 0
回答已采纳
import jsonimport sysimport osfrom google.cloudfrom datetime import date, timedelta
credentials = service_account.Credentials.from_service_account_file("&
浏览 18提问于2022-04-22得票数 0
Processing stuck in step Sink-Spanner/Write mutations to Cloud Spanner/Write mutations to Spanner forat com.google.cloud.spanner.spi.v1.GapicSpannerRpc.get(GapicSpannerRpc.java:556)
at com.google.cloud.spanner.spi.v1.GapicSpannerRpc.c
浏览 8提问于2019-09-06得票数 0
2回答
0].id}" project = local.monitored_resource_project/logging.bucketWriter" project = var.monitoring_project google_logging_project_sink.insta
浏览 16提问于2022-11-08得票数 0
我创建了一个Cloud (导出到发布/子主题)，但它只扫描当前项目的BigQuery表修改日志。我相信这是因为谷歌逐个项目的日志记录范围。滤波器 "google.cloud.bigquery.v2.T
浏览 4提问于2021-06-14得票数 0
回答已采纳
1回答
当尝试使用Google Python3 API客户端创建接收器时，我会得到以下错误：bqclientid_1@id_2.iam.gserviceaccount.com>,
<AccessGra
浏览 2提问于2017-04-22得票数 0
回答已采纳
1回答
-编辑--
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'org.springframework.cloud.stream.app.router.sink.RouterSinkConfiguration:56) ~[spring-cloud-starter-stream-sink-router-1.2.0.M1.jar!$$e55af1a0.CGLIB$router$
浏览 1提问于2017-03-09得票数 1
回答已采纳
1回答
为了实现这一点并避免使用80以外的其他端口，我们决定在我们的实例上设置多个内部IP地址，这是可以使用以下方法的：https://cloud.google.com/compute/docs/networking
浏览 0提问于2016-09-01得票数 -1
下面是函数func.py import redef is_all_log_entries_sink(sink): assert func.is_all_log_entries_sink(sink) == 0
sink
浏览 15提问于2019-12-24得票数 3
我无法通过web和ssh连接到GCP中的任何计算实例。我试图访问并得到这个错误：我也试图通过串行控制台进行连接，但我还没有获得实例的默认凭据。我知道我可以通过用户数据添加用户，但是有生产实例，我不能重新启动它.我不知道这是怎么回事，因为我有其他的项目，配置相同，云端相同，我可以通过SSH连接到上面。
有什么解决办法吗？
浏览 0提问于2022-01-18得票数 0
我想要创建一个Log Sink来侦听Stack驱动程序中的特定消息，并将事件推送到Cloud /Sub，这将触发一个Cloud函数。 name = join("-", concat(["dataflow-events", var.environment, terraform.workspa
浏览 1提问于2020-11-13得票数 7
回答已采纳
我正在尝试使用Ruby直接将字符串有效负载上传到Google Storage。但是，如果不在磁盘中创建一个临时文件，似乎没有直接的方法可以做到这一点。 我正在使用CSV库来生成字符串有效负载。当前的方法建议将字符串payload存储在一个临时文件中，然后使用类似下面的代码将该文件上传到google存储： require "google/cloud/storage"
浏览 18提问于2021-09-29得票数 0
回答已采纳
-0) [INFO - com.google.cloud.hadoop.util.LogUtil.info(LogUtil.java:142)] GHFS version: 1.3.0-hadoop2<init>(BufferedOutputStream.java:76)
浏览 3提问于2014-12-01得票数 0
回答已采纳
我们是否可以在GCP中监控组织政策层面所做的更改。想知道如果一个组织管理员在组织级别策略中进行了更改，那么其他组织管理员应该实时知道这一点。那么，我们可以在gcp中为这种组织级别的更改设置警报吗？
浏览 11提问于2020-09-03得票数 0
回答已采纳
1回答
我已经创建了一个方法，它通过google云存储从一个被调用的文件夹中传输一定数量的图像，但是在运行时它会创建目录，但不会传输任何图像 def Cloud_Transfer(UserLabel, UserCounter
浏览 9提问于2019-05-11得票数 0
我们得到了下面提到的translate.googleapis.com错误。我们没有超过限制，并且比前一天使用的少。有人知道这里的问题吗？ "message": "8 RESOURCE_EXHAUSTED: Quota Error: RESOURCE_EXHAUSTED Quota exceeded for quota metric 'v2 and v3 general model characters' and limit 'v2 and v3 general model characters per day' of service &
浏览 26提问于2020-12-10得票数 0
HA VPN实现(两个对等项都是Google HA VPN )需要访问对等项VPN网络详细信息。与传统VPN不同，我们只需要提供对等VPN的外部IP。我还尝试在HA-VPN配置中提到对等VPN为本地VPN或非Google所有的VPN。然而，这失败了，因为我的对等VPN外部IP属于Google。
浏览 19提问于2021-07-12得票数 0
我想要一个数据流模板，其中一个PipelineOptions参数有默认值。 受在线示例的启发，我使用ValueProvider占位符在我的PipelineOptions“sub”-interface中设置延迟参数： @Default.String("MyDefaultValue") void setMyValue(ValueProvider<String> value); 如果我在运行时指定该参数，该模板将用于启动实际的GCP数据流作业。但是，如果我在真正这样做之前尝试
浏览 11提问于2020-07-23得票数 2
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号