google-cloud-pubsub 相关问题

使用托管在Google基础架构上的可靠，多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展，并为构建您自己的强大全球服务奠定基础。

(deploy-functions) kernal42@space42 KT % podman run --rm -v /Users/kernal42/Downloads/my-project-anp-c94dc8530044.json:/app/key.json:ro --env=GOOGLE_APPLICATION_CREDENTIALS=/app/key.json localhost/rtsink:latest INFO:root:Creating topic: projects/my-project-anp/topics/kt-test-local-15 INFO:root:Topic created: projects/my-project-anp/topics/kt-test-local-15 ERROR:root:Sink not found: projects/my-project-anp/sinks/kt-test-local-15 Traceback (most recent call last): File "/app/main.py", line 41, in setup_pubsub_logsink existing_sink = config_client.get_sink(request={"sink_name": sink_path}) File "/usr/local/lib/python3.10/site-packages/google/cloud/logging_v2/services/config_service_v2/client.py", line 2199, in get_sink response = rpc( File "/usr/local/lib/python3.10/site-packages/google/api_core/gapic_v1/method.py", line 131, in __call__ return wrapped_func(*args, **kwargs) File "/usr/local/lib/python3.10/site-packages/google/api_core/retry/retry_unary.py", line 293, in retry_wrapped_func return retry_target( File "/usr/local/lib/python3.10/site-packages/google/api_core/retry/retry_unary.py", line 153, in retry_target _retry_error_helper( File "/usr/local/lib/python3.10/site-packages/google/api_core/retry/retry_base.py", line 212, in _retry_error_helper raise final_exc from source_exc File "/usr/local/lib/python3.10/site-packages/google/api_core/retry/retry_unary.py", line 144, in retry_target result = target() File "/usr/local/lib/python3.10/site-packages/google/api_core/timeout.py", line 130, in func_with_timeout return func(*args, **kwargs) File "/usr/local/lib/python3.10/site-packages/google/api_core/grpc_helpers.py", line 78, in error_remapped_callable raise exceptions.from_grpc_error(exc) from exc google.api_core.exceptions.NotFound: 404 Sink kt-test-local-15 does not exist INFO:root:Creating sink: kt-test-local-15 INFO:root:Created new sink with writer identity: serviceAccount:[email protected] INFO:root:getting the iam policy for the sink: projects/my-project-anp/sinks/kt-test-local-15 ERROR:root:Error setting up pubsub and logsink: 403 User not authorized to perform this action. Traceback (most recent call last): File "/usr/local/lib/python3.10/site-packages/google/api_core/grpc_helpers.py", line 76, in error_remapped_callable return callable_(*args, **kwargs) File "/usr/local/lib/python3.10/site-packages/grpc/_channel.py", line 1181, in __call__ return _end_unary_response_blocking(state, call, False, None) File "/usr/local/lib/python3.10/site-packages/grpc/_channel.py", line 1006, in _end_unary_response_blocking raise _InactiveRpcError(state) # pytype: disable=not-instantiable grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with: status = StatusCode.PERMISSION_DENIED details = "User not authorized to perform this action." debug_error_string = "UNKNOWN:Error received from peer ipv4:142.250.193.202:443 {grpc_message:"User not authorized to perform this action.", grpc_status:7, created_time:"2025-02-15T05:19:05.783737357+00:00"}" > The above exception was the direct cause of the following exception: Traceback (most recent call last): File "/app/main.py", line 98, in <module> setup_pubsub_logsink(PROJECT_ID, TOPIC_NAME, SINK_NAME) File "/app/main.py", line 68, in setup_pubsub_logsink policy = publisher.get_iam_policy(request={"resource": topic_path}) File "/usr/local/lib/python3.10/site-packages/google/pubsub_v1/services/publisher/client.py", line 1940, in get_iam_policy response = rpc( File "/usr/local/lib/python3.10/site-packages/google/api_core/gapic_v1/method.py", line 131, in __call__ return wrapped_func(*args, **kwargs) File "/usr/local/lib/python3.10/site-packages/google/api_core/grpc_helpers.py", line 78, in error_remapped_callable raise exceptions.from_grpc_error(exc) from exc google.api_core.exceptions.PermissionDenied: 403 User not authorized to perform this action. (deploy-functions) kernal42@space42 KT %

docker google-cloud-platform google-cloud-pubsub google-iam google-cloud-logging

回答 1 投票 0

在GCP Pub/sub？

c# google-cloud-platform google-cloud-pubsub

回答 1 投票 0

在异步堆栈中使用subscribe（）方法

python multithreading python-asyncio google-cloud-pubsub

回答 0 投票 0

在Pubsub

：

google-cloud-platform google-cloud-pubsub

回答 0 投票 0