尝试在Java中对Google pubsub执行同步拉取时出错
在Java中对Google Pub/Sub执行同步拉取时出错可能是由于以下原因之一：
- 认证问题：请确保您的应用程序具有正确的身份验证凭据，以便访问Google Pub/Sub服务。您可以使用Google Cloud Console创建服务帐号，并为其分配适当的角色和权限。
- 依赖库问题：请确保您的Java项目中已正确导入Google Cloud Pub/Sub客户端库。您可以使用Maven或Gradle等构建工具添加以下依赖项：
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-pubsub</artifactId>
<version>版本号</version>
</dependency>- 访问网络问题：请确保您的应用程序可以访问Google Pub/Sub服务。检查您的网络设置，确保没有任何防火墙或代理阻止了与Google Pub/Sub的通信。
- 订阅不存在或权限不足：请确保您尝试拉取消息的订阅存在，并且您的应用程序具有足够的权限来执行拉取操作。您可以使用Google Cloud Console检查订阅的状态和权限设置。
- 代码错误：请检查您的Java代码，确保正确使用Google Pub/Sub客户端库的API。可能存在语法错误、逻辑错误或错误的参数传递。
如果您能提供更具体的错误信息或代码示例，我可以为您提供更详细的帮助和解决方案。
相关·内容
我需要检查我的订阅在过去15天内是否有任何拉动，我应该考虑哪个指标？
我对这个google pubsub stackdriver指标还很陌生，并对它们感到困惑。谁能告诉我这些指标之间的区别：
订阅/拉取消息操作计数
订阅/拉取请求计数
订阅/pull_ack_message_operation_count
订阅/pull_ack_request_count
浏览 1提问于2017-03-01得票数 2
使用gcloud-java pubsub API 0.2.6 -如何通过订阅拉取将"Return Immediately“标志设置为TRUE？
浏览 13提问于2016-07-28得票数 2
回答已采纳
全,
我正在尝试学习如何使用GCP PubSub，并且我能够通过CLI命令(创建主题、订阅、发布到主题、从订阅中拉出等)来测试它，但是当我跳到python ( 2.7版，当前的公司标准)时，我正在努力以同步的方式拉取消息。
我已经检查了这个url，它告诉你去睡觉，虽然是真的，但我无法想象在现实世界中会有人这样做，对吧？
这个url告诉您可以使用future.result()，这是我尝试过的，但它不会像您想象的那样阻塞会话/线程：
还有没有别的主意？下面是我的函数，它直接取自其中一个例子：
def sample_receive_messages(subscription_name="my
浏览 17提问于2018-01-11得票数 3
我尝试使用GrpcSubscriberStub进行“同步拉”，如示例https://cloud.google.com/pubsub/docs/pull中所示 SubscriberStubSettings subscriberStubSettings =
SubscriberStubSettings.newBuilder()
.setTransportChannelProvider(
SubscriberStubSettings.defaultGrpcTransportProviderBuilder()
.setM
浏览 21提问于2020-01-23得票数 2
我们正在以一种“尖峰”的方式使用谷歌PubSub，在短时间内(~ 10分钟)发布数百万条小消息(< 10k)，用10个工作线程旋转2k GKE吊舱，每个线程使用同步拉和确认PubSub服务调用来完成相关的订阅(有10分钟的确认截止时间)。订阅待办事项的Stack驱动程序图将显示1000万条消息的峰值，然后在大约30分钟内向下倾斜到0(见下文)。
我们注意到，随着这些积压文件的数量从100万增加到1000万，在某些小时内从1%以下增加到10%以上，消息重发的数量也随之增加。
来自GAE任务拉队列世界，我们假设工作人员将通过从PubSub订阅中提取一条消息来“租赁”一条消息，其中，从提取时开
浏览 1提问于2020-06-27得票数 2
回答已采纳
1回答
我有一个简单的shell脚本，可以连接到GCP并尝试从主题中提取发布/订阅消息。
当启动时，它检查是否存在任何消息，如果存在，执行一个简单的操作，然后确认消息并循环。
看起来是这样的：
while [ 1 ]
do
gcloud pubsub subscriptions pull...
// Do something
gcloud pubsub subscriptions ack ...
done
随机地，它不拉取消息:它们留在队列中，不被拉取。
因此，我们尝试在获取消息时添加一个while循环，例如5次重试，以避免这些问题工作得更好，但不是很完美。我也觉得这有点寒酸……
这
浏览 14提问于2021-05-20得票数 0
因此，尽管本主题中有大量挂起的消息，拉方法有时仍会返回0条消息。我做错了什么吗？
import os
from google.cloud import pubsub
import ast
PROJECT_ID = os.environ['PROJECT_ID']
subscriber = pubsub.SubscriberClient()
subscription_path = subscriber.subscription_path(PROJECT_ID, 'subscription-name')
while True:
response = subs
浏览 5提问于2021-09-20得票数 0
回答已采纳
1回答
我有一个pubsub主题，有一个订阅，有两个不同的订阅者从中提取。使用stackdriver，我可以看到订阅有大约1000条消息。每个订阅者运行以下轮询循环：
client = pubsub.Client()
topic = client.topic(topic_name)
subscription = pubsub.Subscription(subscription_name)
while True:
messages = subscription.pull(return_immediately=True, max_messages=100, client=client)
浏览 9提问于2016-08-29得票数 2
我使用的是Android Studio 3.0.1，项目使用的是SDK版本26。我尝试使用'grpc- PubSub -v1‘库从谷歌云pubsub模块拉取消息，并在应用程序build.gradle中添加以下行：
compile ('com.google.api.grpc:grpc-pubsub-v1:0.0.2')
当gradle同步出现下一个错误时：
错误:对task':app:transformDexArchiveWithExternalLibsDexMergerForDebug'.执行失败dex : com.android.builder.dex
浏览 45提问于2018-05-04得票数 0
我发现这两种方法都在Google的不同文档中使用：
from google.cloud import pubsub
载于：
鉴于
from google.cloud import pubsub_v1
在以下文件中找到：
浏览 1提问于2018-01-10得票数 14
回答已采纳
2回答
我想利用与GCP CLI for Pub/subscription类似的拉取请求：
gcloud pubsub订阅拉取--filter
我希望在Java客户端库中利用同样的功能。
有没有办法做到这一点？
谢谢。
浏览 6提问于2021-10-06得票数 0
我正在尝试在Spark应用程序中使用谷歌云PubSub。为了简单起见，我们只说这个应用程序是Spark的shell。尝试实例化Publisher会抛出NoClassDefFoundError，这很可能是依赖项版本冲突的结果。然而，通过这样一个简单的设置(只有Spark和一个Google Cloud PubSub依赖项)，我想不出如何解决这个问题。
bash-4.4# spark-shell --packages com.google.cloud:google-cloud-pubsub:1.105.0
Ivy Default Cache set to: /root/.ivy2/cache
The
浏览 17提问于2020-05-07得票数 0
1回答
我正在尝试在执行器中使用，但是当我调用/执行器/健康时，程序会抛出以下内容：
java.lang.NoSuchMethodError: 'com.google.api.gax.rpc.StubSettings$Builder com.google.cloud.pubsub.v1.stub.SubscriberStubSettings$Builder.setBackgroundExecutorProvider(com.google.api.gax.core.ExecutorProvider)'
at com.google.cloud.spring.pubsub.suppo
浏览 7提问于2022-05-17得票数 0
3回答
我非常困惑为什么我的gcloud pub/sub队列在同步打包消息后没有缩小。我有一个很小的队列(不超过几百条消息)，并且使用的代码与gcloud文档中的代码非常相似：
from google.cloud import pubsub_v1 as pubsub
NUM_MESSAGES = 1
PROJECT = 'my_project'
SUBSCRIPTION = 'my_sub'
subscriber = pubsub.SubscriberClient()
subscription_path = subscriber.subscription_path(
浏览 0提问于2020-11-02得票数 0
我已经在下面的文档中浏览了google提供的客户端库。给定的客户端库只是从PubSub轮询消息，但在我们创建无界源连接器之前，它不会连续轮询。https://cloud.google.com/pubsub/docs/pull#synchronous_pull 由于我正在尝试构建的源连接器是无界源，因此我需要注意检查点标记，实现PubSub阅读器，PubSub拆分源，并实现确认和NACK逻辑，我相信创建我自己的无界源连接器需要很长时间。目前PubSubIO(Beam )只支持异步拉取。那么，有没有什么方法可以在Apache Beam提供的PubSubIO api之上实现ACK n NACK逻辑
浏览 19提问于2021-01-10得票数 0
回答已采纳
我正在编写一个application应用程序，其中我使用了.NET PubSub模拟器，在那里我可以发布和订阅一个主题。但是，当我发布“大量”消息1000+时，我想拉出尽可能多的消息。
我使用提供SubscriberServiceApiClient的Google.Cloud.PubSub.V1库与他们的应用程序接口进行交互。我使用具有参数maxMessages的PullAsync方法进行异步拉取。根据他们的文档，这决定了每个请求可以提取的最大消息数，但是它可能会返回更少的消息。如果我提供一个参数来指定一个大于100的maxMessages数，这将不会有什么不同。这意味着我可以从每个请求接收的最
浏览 10提问于2018-03-02得票数 1
尝试在我的AppEngine中使用AppEngine，我添加了以下内容
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-pubsub</artifactId>
<version>0.6.0</version>
</dependency>
当我试图获取我的PubSub实例时
PubSub pubsub = PubSubOptions.getDefaultInstance().ge
浏览 5提问于2016-11-22得票数 1
回答已采纳
我正在尝试使用Google Pub/Sub连接器与Flink，请看这里。 然而，我得到了 Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.google.cloud.pubsub.v1.stub.GrpcPublisherStub 我有连接器的依赖版本是1.9.0 <dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-co
浏览 6提问于2019-08-30得票数 1
1回答
把替罪羊改成了更普通的。我想问题不在于这个类别的特殊性。
我想模拟google.cloud.pubsub_v1.SubscriberClient，我想在调用客户端的拉函数时设置一个假的返回值。
prod代码:来自google.cloud导入pubsub_v1
def open_subscription() -> None:
with pubsub_v1.SubscriberClient() as subscriber:
logger.info(f'Listening for messages on {config.SUBSCRIPTION_NAME}
浏览 11提问于2022-02-13得票数 2
1回答
我正在尝试使用https://github.com/GoogleCloudPlatform/DataflowTemplates和direct runner在本地运行PubSubToBigQuery.java。但是，我收到了错误消息 Exception in thread "main" java.lang.IllegalArgumentException: Class interface com.google.cloud.teleport.templates.PubSubToBigQuery$Options missing a property named 'gcs-l
浏览 20提问于2019-01-22得票数 1
1回答
我正尝试在我的机器上使用google pub sub模拟器来创建一个主题。
但是，当我尝试执行创建主题的代码时，我得到了一个TestTimedOutException。
我正在尝试执行谷歌在其上提供的步骤/代码。
下面是我的代码：
public static void main(String args[] ){
//project id
String projectId = ServiceOptions.getDefaultProjectId();
//topic id
String topicId = args[0];
// Create a new top
浏览 0提问于2019-08-31得票数 0
我有一个订阅PubSub主题并使用异步拉的服务。在空闲10分钟并没有收到任何消息后，PubSub抛出504个截止日期超过错误。
错误总是在大约10分钟后发生。我发现的每一个类似的问题都与同步拉有关，而不是我使用的异步拉。
错误消息：
INFO:google.cloud.pubsub_v1.subscriber._protocol.streaming_pull_manager:Observed non-terminating stream error 504 Deadline Exceeded
浏览 1提问于2020-07-09得票数 3
回答已采纳
2回答
我很难用javascript/Nodejs8 8 Google函数将有效负载发布到Google PubSub。
因此，我有一个由HTTP请求触发的云函数，然后将请求体发布到一个pubsub (配置为拉模式)。
这是我的代码：
const {PubSub} = require('@google-cloud/pubsub');
const pubsub = new PubSub();
const topic = pubsub.topic('my-fancy-topic');
function formatPubSubMessage(reqObj){
//
浏览 12提问于2019-10-09得票数 0
回答已采纳
我使用gloud-java实验库。今天更新后，出现错误。从库本地运行示例(这个错误会自动出现在google cloud flexible engine中，尽管deploy在一周内没有生成)
public class PullTest {
private static final transient Logger logger = Logger.getLogger(MethodHandles.lookup().lookupClass().getName());
public static void main(String... args) throws Exception {
try
浏览 0提问于2016-08-10得票数 1
我对Node.js的Node.js模块有个问题。我使用Docker和PubSub模拟器创建了一个本地环境。我能够发布一条消息并使用异步拉检索它(如这里所记录的：)。然而，当我试图使用同步拉()时，我一直有以下错误：
错误:无法加载默认凭据。浏览到以获得更多信息。在GoogleAuth。(/var/code/node_modules/google-auth-library/build/src/auth/googleauth.js:167:23) at next (本机)在实现的(/var/code/node_modules/google-auth-library/build/src/auth/
浏览 0提问于2018-11-29得票数 1
回答已采纳
我们的应用程序使用Google PubSub(Publisher-订户)进行跨服务的异步通信。在应用程序中的一个服务中，它检查主题(发布者)名称在PubSub中是否存在。如果PubSub中不存在主题(Publisher)名称，则服务具有重新启动时创建主题(Publisher)名称的逻辑，否则它会记录主题(Publisher)名称已经存在于Google中的消息。
问题描述：
在JSON存储在文件中并上传到 S3的服务上构建了一个新特性。作为该功能的一部分，AWS S3依赖项必须添加到Gradle文件中。在Gradle启用AWS S3依赖项之后，PubSub在获取主题名称(在PubSub中已经存在
浏览 3提问于2021-01-21得票数 0
我已经用指向本地PubSub仿真器的根url设置了Pubsub.Builder (在我的例子中是localhost:8036)。它似乎在工作，我看到模拟器正在接收我的测试推送，但给我错误400错误的请求。
发布代码：
auth = GoogleCredential.getApplicationDefault(HTTP_TRANSPORT, JSON_FACTORY)
.createScoped(PubsubScopes.all());
client = new Pubsub.Builder(HTTP_TRANSPORT, JSON_FACTORY, auth)
浏览 0提问于2016-01-27得票数 2
1回答
我正试图在Google上找到一份数据流工作。它总是失败，因为：
io.grpc.protobuf.ProtoUtils.marshaller(Lcom/google/protobuf/Message;)Lio/grpc/MethodDescriptor$Marshaller :java.lang.NoSuchMethodError
这是一个maven项目，下面是我的依赖项：
<dependencies>
<dependency>
<groupId>com.google.cloud.dataflow</groupId>
<
浏览 1提问于2016-12-02得票数 1
回答已采纳
当我尝试从docker hub拉取jenkins图像(docker pull jenkins)时，在下载时它报告要求身份验证错误。请提个建议。
浏览 0提问于2016-12-22得票数 0
几个小时以来，我一直试图获得Spring应用程序的骆驼路由(通过Camel组件连接到的本地实例)，但没有成功。
我的模拟器正在运行：
❯ gcloud beta emulators pubsub start --host-port=localhost:8085 --project=local
Executing: /usr/lib/google-cloud-sdk/platform/pubsub-emulator/bin/cloud-pubsub-emulator --host=localhost --port=8085
[pubsub] This is the Google Pu
浏览 3提问于2020-12-03得票数 2
我已经用Java启动了一个新项目，并希望将其部署在Google Cloud平台(而不是App Engine！)上。我还想使用GCP提供的一些服务/产品: Datastore、PubSub等。
我从数据存储开始，发现了一个很好的库：
然后我决定开始使用PubSub，并发现gcloud-java没有任何与PubSub相关的东西。下面是一些支持Java PubSub的库：
所以，我只是想确认(因为这对我来说太奇怪了)，Google没有为他们的服务提供统一的Java库？除了使用两个库(使用不同的策略来管理凭据等)之外，我别无选择？
如有任何帮助/建议，我们将不胜感激！提前谢谢你。
浏览 1提问于2016-06-20得票数 0
我正在尝试使用GCP Java SDK通过以下代码向发布/订阅主题发送消息(在此代码片段中用占位符替换实际的项目ID和主题名称)：
Publisher publisher = null;
ProjectTopicName topic = ProjectTopicName.newBuilder()
.setProject("MY_PROJECT_ID")
.setTopic("MY_TOPIC")
.build();
try {
publisher = Publisher.newBuilder(topic)
浏览 8提问于2019-07-28得票数 0
我正在尝试构建一个流/批处理管道，它从发布/订阅中读取事件，并使用python3.6将它们写入BigQuery 根据文档，云发布/订阅会为每条消息分配唯一的message_id和timestamp，用于检测订阅者收到的重复消息。(https://cloud.google.com/pubsub/docs/faq) 要求如下: 1)消息可以以任意顺序传入(异步消息) 2)唯一Id和时间戳(当记录被推送到pubsub主题/从主题拉取时)需要捕获到已有的记录中。 Input Data :
Name Age
xyz 21 Output Record to bigquery:
Name Age
浏览 13提问于2019-10-16得票数 0
2回答
我正在尝试实现Spring /Sub，我遵循了指南，但是如何将异常降低，这使得它开始消耗大量的处理，我进行了大量的研究，他们说要放置参数awaitTerminated，但是我找不到如何定义这个参数。
版本：
<spring-cloud-gcp.version>2.0.4</spring-cloud-gcp.version>
<spring-cloud.version>2020.0.4</spring-cloud.version>
豆子
@Bean
public DefaultPublisherFactory defaultPublisherFac
浏览 79提问于2021-12-22得票数 0
回答已采纳
我们正在构建一个Graylog输出插件来将数据发送到Google PubSub。这是我们编写的代码，灵感来自于google pubsub (和)提供的样板代码。
try (InputStream credential = new FileInputStream(Objects.requireNonNull(config.getString(CK_CREDENTIAL_FILE)))) {
CredentialsProvider credentialsProvider = FixedCredentialsProvider
浏览 44提问于2019-11-19得票数 0
我有一个spring服务，订阅来自google cloud pubsub (拉取)主题的消息。 我已经尝试在我的配置文件配置中设置这些配置。像这样管理消息的重试： spring:
cloud:
gcp:
pubsub:
subscriber:
retry:
max-attempts: 2
retry-delay-multiplier: 5
initial-retry-delay-seconds: 1
max-retry-delay-sec
浏览 10提问于2019-05-02得票数 0
我尝试在appEngine (在我的web.xml中定义了java8 )上运行这段代码
public TopicName createTopic(final String topicNameStr) throws Exception {
checkInit();
final TopicAdminSettings topicAdminSettings =
TopicAdminSettings.defaultBuilder()
.setChannelProvider(channelProvider)
浏览 0提问于2017-07-12得票数 8
我有两个项目--A项目和B项目。
在Project上，我有一个服务帐户loader@project-a.iam.gserviceaccount.com，我想使用它来读取来自Project主题的消息。
我在Project projects/project-b/subscriptions/data上创建了一个主题订阅。然后在权限选项卡中添加loader@project-a.iam.gserviceaccount.com作为Subscriber。我相信它应该能让我进入。
但如果我尝试：
TestIamPermissionsRequest iamreq = new TestIamPermissions
浏览 4提问于2016-02-29得票数 0
我正在尝试用Python语言处理seek(timestamp)返回的消息。 我订阅了使用流式拉取的非搜索消息： subscriber = pubsub_v1.SubscriberClient()
subscription_path = subscriber.subscription_path(project_id, subscription_id)
future = subscriber.subscribe(subscription_path, callback=callback())
with subscriber:
try:
future.result()
浏览 12提问于2021-03-23得票数 0
回答已采纳
2回答
我正在尝试使用Python构建一个使用Google Cloud Platform AutoML的应用程序。我的整体代码流如下所示：
用户交互-->数据发送到PubSub-->回调调用我的AutoML-->结果
调用pubsub的代码片段如下所示：
blob=blob+bytes(doc_type,'utf-8')
publisher.publish(topic,blob)
future=subscriber.subscribe(subscription,callback=callback)
#flash("
浏览 2提问于2018-09-04得票数 2
1回答
我正在用Java开发数据流，输入来自一个Pubsub。后来，我看到了关于如何使用本地Pubsub仿真器的指南here，这样我就不需要为了测试而部署到GCP。 下面是我的简单代码： private interface Options extends PipelineOptions, PubsubOptions, StreamingOptions {
@Description("Pub/Sub topic to read messages from")
String getTopic();
void setTopic(String topic);
浏览 13提问于2020-04-10得票数 0
回答已采纳
1回答
我试图在gcp上使用terraform来实现以下目标。
云函数侦听添加到发布/副主题中的消息，一旦添加消息，云函数将被触发，如果在处理该消息时出错，则将消息放入相应的死信队列。
我不知道如何创建云功能的订阅，它也包含死信策略。目前，我正在为云函数执行以下操作，
resource "google_cloudfunctions_function" "brw-user-function-item-registered" {
// details
event_trigger {
event_type = "google.pubsub.topic.
浏览 3提问于2021-08-12得票数 0
2回答
我已经设置了PubSub模拟器，以便在本地运行指向它的Python脚本。
仿真器是按照本教程运行的，它似乎运行得很好：
➜ gcloud beta emulators pubsub start --project=tokyo-rain-123 --host-port=127.0.0.1:8085
Executing: /Users/pabloruiz/Downloads/google-cloud-sdk/platform/pubsub-emulator/bin/cloud-pubsub-emulator --host=127.0.0.1 --port=8085
[pubsub] This is
浏览 33提问于2022-11-17得票数 0
1回答
Azure移动同步，数据未更新
、、、、
我有一个使用Azure移动同步的iOS/Android应用程序。大多数时候，一切都像你所期望的那样工作，但有一个场景一直困扰着我。场景是：
电话A会创建一条记录。电话B会创建一条记录。电话A更新电话B的记录。电话B更新电话A的记录。Phone C从云中正确地获得了记录创建和最新更新。电话A有它的原始记录，但无法拉入电话B的更新。电话B有它的原始记录，但无法拉入电话A的更新。
我已经验证了不存在同步冲突，数据正在被拉取，并且大多数情况下不会发生这种情况。大多数情况下，电话A/B/C都会正确更新。我从我的Android手机中提取了sqlite数据库，并且我已经检查了_operations表，我没有
浏览 3提问于2018-08-09得票数 2
我有一个使用Google Cloud Pubsub的Python应用程序，如下所示：
from google.cloud import pubsub
它在本地运行得很好，但在调用AWS Lambda函数时，我得到了：
Unable to import module 'handler': cannot import name 'pubsub'
并且没有其他错误或详细信息。
我的requirements.txt文件：
requests
google-cloud-datastore==1.4.0
google-cloud-pubsub==0.29.0
sqlalche
浏览 2提问于2017-11-19得票数 0
设置为：
我设置了一个主题来接收消息，然后使用设置了一个Dataflow管道，该管道可以将消息转储到GCS桶中的窗口文本文件中。这很好--我最终在GCS中获得了包含我通过控制台发送的测试消息的文件，在我的主题上使用了“发布消息”按钮(我还以为它会保存消息的“数据”部分，但看起来它只保存消息体)。但我可以解决这个问题)。
问题：
我打算使用python客户机(最终来自intending )...but向主题发送消息--当我从本地机器发送消息时，它无法工作。下面是中使用pubsub_v1模块的简单示例。即使将批处理设置设置为1kb/1s，我也无法获得任何成功发布的信息。在未来的5分钟之后，我一直收
浏览 0提问于2018-07-03得票数 0
我正在尝试使用go客户端库一次从pub-sub订阅中拉出一条消息。但是，即使订阅上存在消息，消息也不会拉取请求。订阅者正在等待处理所有消息。
我正在尝试go中的基本代码，在go中我一次拉出一条消息。我使用了两个实例，并在这两个实例的后台运行了4次脚本(以创建订阅者)。我已将ack_deadline设置为10秒。我期待的结果像每个订阅者应该采取订阅后的下一条消息确认一条消息。但是直到最后一条消息处理完成后，消息才会在实例上拉取。为什么处理完一条消息后没有拉取消息？据我所知，应该不存在对实例或订阅者的任何依赖。让mi知道需要设置的任何其他更改或参数。提前谢谢。
以下是一个实例的日志：
2019/1
浏览 2提问于2019-10-21得票数 0
我一直在犯这个错误：
Exception in thread "main" java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;I)V
at com.google.cloud.pubsub.v1.Subscriber.<init>(Subscriber.java:138)
at com.google.cloud.pubsub.v1.Subscriber.<init>(Subscriber.jav
浏览 0提问于2018-03-01得票数 3
回答已采纳
我试图用最基本的设置运行这个插件：
input {
google_pubsub {
# Your GCP project id (name)
project_id => "cosmic-keep-148903"
# The topic name below is currently hard-coded in the plugin. You
# must first create this topic by hand and ensure you are exporting
# lo
浏览 25提问于2022-08-18得票数 0
回答已采纳
我正在尝试在云函数中导入pubsub_v1。但是当我尝试在GCP上部署它时，标题中的问题就出来了。与main.py文件位于同一目录中的requirements.txt文件。以下是requirements.txt中的内容：
google-api-core==1.3.0
google-auth==1.5.1
google-cloud-core==0.28.1
google-cloud-storage==1.10.0
google-resumable-media==0.3.1
googleapis-common-protos==1.5.3
google-api-python-client==1.7.
浏览 2提问于2018-10-04得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
