处理卡在步骤Sink中- Spanner /将突变写入云Spanner/将突变写入Spanner至少05m00s，而不输出或在状态过程中完成 正在写入扳手，但引发此错误 PCollectionTuple spanMutTuple = pColIfEnrichMsgs.apply("CreateMutation",
ParDo.of(new SpannerMutation(options, ttSpanMutOutMsgs, erroMessage))
.withOutputTags(ttSpanMutO
浏览 8提问于2019-09-06得票数 0
我想从扳手中提取一个巨大的表，而不是常规的execute_sql函数，我希望流数据。但我没看到太多的文件。
我正在使用google云python库，我也找不到解决方案
有人试过吗？
import os,sys
import subprocess
import glob
from os import path
from google.cloud.spanner_v1.streamed import StreamedResultSet
def run_quickstart():
# [START spanner_quickstart]
# Imports the Google Cl
浏览 0提问于2018-06-19得票数 0
回答已采纳
1回答
我正在尝试查询Spanner上的自定义SQL并将结果转换为Pandas Dataframe，因此我需要数据和列名，但我找不到获取列名的方法。
根据，我可以使用元数据或字段属性获取列，但这不起作用。
我试图运行查询事务并获取快照，但我只获得了一个数据行。
from google.cloud import spanner
from google.cloud.spanner_v1.streamed import StreamedResultSet
def query_transaction(instance_id, database_id, query_param):
spanner_c
浏览 12提问于2019-08-09得票数 1
回答已采纳
1回答
我正在尝试设置Alembic来使用Google，但是无论我如何尝试，在尝试运行一个简单的“alembic upgrade head”时，我都会出现以下错误之一：
sqlalchemy.exc.NoSuchModuleError:无法加载插件: sqlalchemy.dialects:spanner
KeyError：'spanner+spanner‘
--我已经尝试过了：
在alembic.ini for sqlalchemy.url中：
spanner:///projects/<project>/instances/<instance>/dat
浏览 13提问于2022-08-09得票数 1
Cloud Spanner提供了两种不同的API。Cloud Spanner read和Cloud Spanner SQL API有什么区别？
浏览 10提问于2017-02-18得票数 4
回答已采纳
1回答
我可以直接从本地机器连接到扳手模拟器，但在尝试从docker容器连接到它时遇到了问题。
我的组合文件中有以下两个服务：
version: '3.7'
services:
serviceA:
image: "test
depends_on:
- spanner-emulator
environment:
SPANNER_EMULATOR_HOST: localhost:9010
spanner-emulator:
image: spanner_image
ports:
- 9010:9
浏览 12提问于2021-02-23得票数 0
(对不起，这是TL，博士，但我很绝望，想要彻底！)
我们正在将服务从AWS转移到GCP，并从DynamoDB切换到云扳手作为后端数据存储。
数据存储(扳手)包含web服务查询用户的数据。在生产负载中，查询的数据在1%到10%之间。我有一个简单的多线程Java测试客户机来查询我们的服务，只要过去1分钟的平均吞吐量不断增加，就会不断添加新的线程。
我的测试客户端运行在GCE (64 CPU)上，当使用DynamoDB数据源时，当我们的服务自动扩展到配置的pod节点计数时，我可以获得最多3700个线程，平均通过50k req/s。每1000次请求，每个线程从Dynamo读取100个散列(命中率10%
浏览 5提问于2021-03-26得票数 0
1回答
这是我的代码：
// vim:ft=javascript:
const {Spanner} = require('@google-cloud/spanner');
const spanner = new Spanner({projectId: 'gcp-in-action-317405'});
const instance = spanner.instance('test-instance');
const database = instance.database('test-database');
const employe
浏览 1提问于2021-06-27得票数 0
回答已采纳
问题
我们正试图通过SQLAlchemy版本1.3.23和连接云扳手。使用Poetry进行依赖关系管理时，添加了如下所示的sqlalchemy-spanner (项目是这样设置的)：
sqlalchemy = "~1.3"
sqlalchemy-spanner = { git="https://github.com/cloudspannerecosystem/python-spanner-sqlalchemy.git", tag="v0.1.0" }
调用create_engine时，
create_engine("spanner:///
浏览 3提问于2021-09-07得票数 1
回答已采纳
1回答
我正在创建一个SpannerSingleton，以便在应用程序生命周期内保持连接。我对连接耐久性感兴趣..。如果存在会话/连接问题，如何重新创建会话？
一个想法是，如果超过90%的池耗尽，则生成一个新的连接，将setMaxSessions增加到更高的数量。就像指数退避的反面？但我在哪里/怎么能做到呢？我无法在客户端库中找到任何允许我监视池状态或客户机计数的内容。
我和一起去的，因为这似乎是个不错的选择.
以下是我所拥有的：
public class SpannerSingleton {
private static Spanner spanner;
private stati
浏览 0提问于2019-02-09得票数 1
回答已采纳
我正在尝试将现有的spring boot应用程序从使用Postgres迁移到GCP Spanner。 我正在使用以下Cloud Spanner JDBC驱动程序和Hibernate方言： <dependency>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-spanner-hibernate-dialect</artifactId>
<version>0.1.0</version>
</dependen
浏览 14提问于2020-03-25得票数 0
回答已采纳
我试过了，这是和。
在本地运行Google扳手模拟器(0.8.0)
export SPANNER_EMULATOR_HOST=localhost:9010
Executing: docker run -p 127.0.0.1:9010:9010 -p 127.0.0.1:9020:9020 gcr.io/cloud-spanner-emulator/emulator:0.8.0
[cloud-spanner-emulator] 2020/07/17 22:23:21 gateway.go:135: Cloud Spanner emulator running.
[cloud-spanner-
浏览 1提问于2020-07-18得票数 0
回答已采纳
无法连接到Googe云扳手与Java代码获取SSLException错误。
用java写了一段代码，它试图连接到Google Spanner，我已经创建了Spanner实例和数据库以及一个表。
但是，当我尝试运行Java代码时，它给出了错误com.google.cloud.spanner.SpannerException的错误:未知: javax.net.ssl.SSLException: unable to setup trustmanager
try (InputStream credentialsStream = new FileInputStream(credentialsFile))
浏览 0提问于2019-09-12得票数 2
1回答
提前感谢您的帮助。
我正在尝试设置每个调用超时在扳手nodejs客户端.我已经阅读了给定的扳手文档，其中最好的是：。这些文档忽略了您需要提供gaxOptions。或者我是个误会，这并不奇怪，因为我无法解释我所看到的行为。
我在这里创建了一个小回购来保存这个复制：。下面还粘贴了代码。
const PROJECT_ID_HERE = "";
const SPANNER_INSTANCE_ID_HERE = "";
const SPANNER_DATABASE_HERE = "";
const TABLE_NAME_HERE = "";
浏览 2提问于2021-10-14得票数 0
回答已采纳
2回答
在本地环境下，使用的docker仿真器创建开发工具。
如果使用minikube，在kubernetes环境中运行其docker，则可以启动其容器
minikube start
eval $(minikube docker-env)
docker run -p 9010:9010 -p 9020:9020 gcr.io/cloud-spanner-emulator/emulator
但无法通过gcloud命令创建实例
gcloud spanner instances create test-env --config=emulator-config --description="Local
浏览 43提问于2021-03-10得票数 0
回答已采纳
昨天我安装了扳手仿真器，它成功地返回了像gcloud spanner databases list --instance=test-instance这样的查询结果。
但是，由于我重新启动了我的机器，当我尝试做一个数据库列表或者任何其他关于这个问题的查询时，我会看到这个特殊的错误。它在每种情况下都返回以下错误-
gcloud spanner databases list --instance=test-instance
ERROR: (gcloud.spanner.databases.list) HttpError accessing <http://localhost:9020/v1/p
浏览 7提问于2021-02-05得票数 0
回答已采纳
1回答
当使用spanner客户端(但问题可能更普遍)时，似乎不可能将结构作为参数传递给查询。
考虑以下设置：
from google.cloud.proto.spanner.v1 import type_pb2
from google.cloud import spanner
spanner_client = spanner.Client()
instance = spanner_client.instance('myinstance')
database = instance.database('mydb')
如果我想将以下查询转换为使用参数
select * f
浏览 2提问于2017-06-08得票数 1
回答已采纳
我正在尝试google云扳手的“使用Python的云扳手入门”指南。
我已经创建了实例数据库e.t.c。
我已经读到了“创建数据库客户端”部分。
我们在防火墙后面操作，并且必须设置我们的代理设置，我们已经成功地使用Gsutil，BQ命令行e.t.c完成了这一点。
当我设置代理设置时，然后尝试执行quickstart.py I get error。
E0620 08:35:32.703000000 5020 src/core/ext/filters/client_channel/uri_parser.c:60] bad uri.scheme: 'xx.xxx.xxx.xxx:xx
浏览 2提问于2017-06-20得票数 1
2回答
我希望在云功能的每个实例中共享对云扳手实例和数据库的引用，这样云函数的每次调用都不会创建到Spanner的新连接。见。
在这个Node.js 8 beta实现中，是否有一个可以关闭到数据库的连接的下拉函数？
myFunction/index.js
const Spanner = require("@google-cloud/spanner");
const spanner = Spanner();
/**
* Maintain a persistent connection instead of creating a new
* connection upon every
浏览 4提问于2018-08-17得票数 2
回答已采纳
2回答
比较列表中的类型
、、
我在Unity3D问答网站上问了一个类似的问题，但没有得到回应。我终于回到了这个项目，仍然有同样的问题。
我已经搜索过了，但我认为我没有找到正确的关键字，因为我仍然没有找到一个合适的答案。无论如何，我会以不同的方式来问这个问题，希望有人能给我指明正确的方向。
下面是我想出的代码，它不是游戏中的实际代码，但它很好地展示了我的问题。
基本上，在build()方法中，我希望检查这两个列表都包含相同类型的工具，而不需要对该类型进行实际的硬编码。我不关心特定的工具实例，只是它是特定类型的。其目的是，我可以创建新的工具，而不必修改构建方法来合并这些新类型。
如果有更好的方法做这件事，我会全神贯注的。
谢
浏览 3提问于2014-05-11得票数 0
回答已采纳
我在Spanner表中有数百万条记录，我想使用一些查询条件从Spanner中删除行。例如:从id > 2000的扳手表中删除。我无法在Spanner UI中运行此查询，因为单个操作中的Spanner 20k突变限制。那么有没有什么方法可以通过在api级别代码中做一些调整来从扳手表中删除此记录，或者我们是否有针对此类用例的变通方法。
浏览 2提问于2020-03-08得票数 1
我有一个数据流作业，它将结果写入云扳手表。当我在本地运行作业时，一切都很好，但是在Dataflow上运行它会出现以下错误-
java.lang.IllegalArgumentException: Jetty ALPN/NPN has not been properly configured.
io.grpc.netty.GrpcSslContexts.selectApplicationProtocolConfig(GrpcSslContexts.java:174)
io.grpc.netty.GrpcSslContexts.configure(GrpcSslContexts.j
浏览 1提问于2017-08-15得票数 1
回答已采纳
我无法让谷歌的在扳手模拟器上运行。我使用的是在MacOS Mojave上预装的JDK11 (AdoptOpenJDK build 11.0.3+7)。
我已经使用我的GCP帐户进行了身份验证，并按照文档中的完成了仿真器设置，按照说明一直到启动仿真器，成功地创建了一个实例，并将SPANNER_EMULATOR_HOST环境变量设置为localhost:9010。
当Spring应用程序运行时，它会失败，并显示以下错误：
java.sql.SQLTransientConnectionException: HikariPool-1 - Connection is not available, req
浏览 13提问于2020-09-23得票数 0
我正在尝试寻找如何使用dotnet core \ C#库删除GCP Spanner实例的示例。 这提供了一个如何创建实例的示例，但我似乎不知道如何通过代码删除实例。https://cloud.google.com/spanner/docs/samples/spanner-create-instance
浏览 17提问于2020-12-17得票数 0
回答已采纳
我是Google云扳手的新手，为了探索它，我从google 提供的文档开始。为了探索任何数据库，我们从数据操作开始，就像我所做的一样，我开始使用这里给出的简单的java应用程序向扳手写入数据。
我在以下代码段所示的各个位置上对驱动程序类进行了更改：
public static void main(String[] args) throws Exception {
String path = "File_Path";
SpannerOptions.Builder options = SpannerOptions.newBuild
浏览 5提问于2017-06-14得票数 4
回答已采纳
2回答
火花JDBC连接到谷歌云扳手故障
、、、、
我正在尝试使用PySpark JDBC连接从读取数据。我的Spark应用程序正在Dataproc集群上运行。我正在使用官方的驱动程序作为查找。下面是PySpark代码的一个片段：
project = <<PROJECT_ID>>
instance = <<INSTANCE_ID>>
databases = <<DATABASE_ID>>
spanner_connection_url = 'jdbc:cloudspanner:/projects/' + project + '/instances/&#
浏览 15提问于2022-08-17得票数 1
通过REST API获取对google spanner的读写操作的以下异常 我手动创建了扳手实例、数据库和表，并尝试读取和写入扳手表，得到此错误。我想知道这个错误是由于配置还是运行时的代码造成的。 帮助我解决此问题 扳手:池已在com.google.cloud.spanner.SessionPool.getReadSession(SessionPool.java:834) ~google-cloud-spanner-1.11.0.jar:1.11.0 at com.google.cloud.spanner.DatabaseClientImpl.singleUse(DatabaseClient
浏览 36提问于2020-03-26得票数 0
1回答
我试图在Apache (DoFn)中添加扳手连接。我需要查找一些行作为ParDo的一部分。数据流创建了许多工作人员(通常为4max)，我使用startBundle和finishBundle方法打开和关闭工人生存期内的扳手连接。然后，在processElement方法中，对传递DatabaseClient并使用singleUseReadOnlyTransaction的每个项执行查找。
我应该补充一下，这是在GCP下作为数据流运行的。
一些代码来说明这一点。
private static CustomDoFn<String, TransactionImport> processRow
浏览 0提问于2018-07-19得票数 1
我想通过云监控api获得云bigtable和Cloud Spanner上各种请求的服务器错误率，但是在云监控中，我只看到这些可用的指标- bigtable - https://cloud.google.com/monitoring/api/metrics_gcp#gcp-bigtable - spanner - https://cloud.google.com/monitoring/api/metrics_gcp#gcp-spanner
浏览 31提问于2021-08-20得票数 0
回答已采纳
2回答
我想将数据从项目A中的Cloud Spanner导出到项目B中的GCS作为AVRO。如果我在项目B中的服务帐户在项目A中被授予spanner.read访问权限，我是否可以使用模板Cloud_Spanner_to_GCS_Avro从项目B中运行数据流作业，并写入项目B中的GCS？ 我在控制台和下面的命令中都尝试过： gcloud dataflow jobs run my_job_name
--gcs-location='gs://dataflow-emplates/latest/Cloud_Spanner_to_GCS_Avro'
--region=my_region
-
浏览 24提问于2020-04-27得票数 0
回答已采纳
1回答
问题：
我们尝试使用扳手runStream通过特定的查询迁移部分数据(数百万数据)(在选择查询中，我们使用了多个表)。
spannerDatabase
.runStream({
sql,
params,
json: true
})
但是在运行了Cloud (256 MB大小)之后，我得到了Error: memory limit exceeded.
调查
经过调查，我发现@google-cloud/spanner使用了partialResultStream，其中maxQueued为10，而且似乎没有合适的params来管理块大小或块数(每个块响应在10万个字段值
浏览 2提问于2020-04-28得票数 0
Google Cloud Spanner是否提供ORM集成？
我尝试在spanner-jdbc和spanner-hibernate(即‘nl topicus’组织提供的方言)的帮助下集成应用程序。我认为这个实现不是hibernate的正式实现，我在实现上遇到了问题，因为如果我需要更改现有的表，我需要使用hbm2ddlauto属性重新创建整个模式。
我正在Spring boot应用程序上实现它。
另外，有人能澄清一下，Google Cloud Spanner有没有可用的本地环境，据我所知，没有解决方案？
浏览 5提问于2018-08-16得票数 0
2回答
在下面的代码片段中，插入多个具有静态值的行。如何在一个事务中将多行动态插入到扳手数据库中？ function writeUsingDml(instanceId, databaseId, projectId) {
const {Spanner} = require('@google-cloud/spanner');
const spanner = new Spanner({
projectId: projectId,
});
const instance = spanner.instance(instanceId);
const da
浏览 26提问于2018-12-22得票数 0
是否有可能在返回的数据中返回列名？
例如，
def query_data(instance_id, database_id):
"""Queries sample data from the database using SQL."""
spanner_client = spanner.Client()
instance = spanner_client.instance(instance_id)
database = instance.database(database_id)
with databas
浏览 2提问于2019-06-29得票数 0
回答已采纳
from google.cloud import spanner
import locust
if __name__ == "__main__":
client = spanner.Client()
query = "select * from table where id=@id"
params={"id": "testId"}
param_types={"id": spanner.param_types.STRING}
with client.instance("
浏览 12提问于2022-05-25得票数 0
1回答
当我单击#tool时，我想将类.spanner添加到div #drill中。
但是，当#drill具有类.spanner并且单击了#tool时，我想要删除该类吗？
浏览 1提问于2010-04-27得票数 2
是否有可用于Oracle到Google Cloud Spanner迁移的工具？另外，Spanner是否支持存储过程、视图、触发器、函数等？
浏览 2提问于2018-10-22得票数 0
我可以知道我哪里做错了吗？我想要实现的是淡出/隐藏段落。当段落淡出时，它会再次出现。 $("div.spanner").addClass("show");
$("div.overlay").addClass("show");
$("p.three").addClass("show").fadeIn(1000).delay(1000).fadeOut(1000); .one, .two, .three, .four{
visibility: hidden;
z-index: 1000;
浏览 13提问于2021-02-05得票数 1
回答已采纳
1回答
我使用云函数和nodeJS客户端库将数据插入到扳手中。Pub/Sub2次/秒左右调用该函数，并使用事务插入数据。
当阅读文档时，它明确表示必须通过调用:database.close()来关闭会话；当我这样做时，它会抛出一个错误：
Error: Database is closed. at SessionPool.<anonymous>
(/srv/node_modules/@google-cloud/spanner/build/src/session-
pool.js:264:23)
at Generator.next (<anonymous>) at /s
浏览 0提问于2019-09-02得票数 1
回答已采纳
1回答
我目前正在为我的本地开发开发扳手模拟器，最终将使用实际的实例。我试图运行一个错误的SQL查询，希望为用户捕获并抛出一条错误消息。
当我使用云运行下面的查询时，我看到HTTPError
gcloud spanner databases execute-sql --project=local-gcp-project testdb --instance=Emulator --sql='SELECT SingerId, AlbumId, AlbumTitle FROM Albums'
(gcloud.spanner.databases.execute-sql) HTTPError 40
浏览 12提问于2021-02-24得票数 1
我正在使用PHP尝试使用谷歌云扳手。我已经做了gCloud设置和所有事情，这是正确的。现在，我需要通过PHP进行连接，以便对扳手中的数据库执行CRUD操作，但是下面的代码总是返回错误：
PHP致命错误:第129行/xxx/xxxx/www/vendor/google/cloud-spanner/Connection/Grpc.php中未定义的常量“Grpc\STATUS_UNKNOWN”
我的代码是：
<?php
require 'vendor/autoload.php';
use Google\Cloud\Spanner\SpannerClient;
/*
浏览 0提问于2017-06-07得票数 2
我有一个连接到云扳手数据库的SpringBoot Java应用程序。不存在w.r.t连接问题，也可以将数据读写到表中，但是在Dynatrace中检查W.r.t连接/跟踪级别日志时，我可以看到，每次调用Spanner都会抛出一个异常。是否有任何配置的扳手，我错过了，或它是什么，我应该担心，如何解决这个问题，如果是一个问题？请帮帮忙。
下面是我的代码中使用的扳手依赖项-
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-s
浏览 8提问于2022-07-13得票数 0
回答已采纳
我正在尝试在GCP数据流管道中运行以下脚本。 import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions
from typing import NamedTuple, Optional
from apache_beam.io.gcp.spanner import *
from past.builtins import unicode
import logging
class ItemRow(NamedTuple):
item_id: unicode
cla
浏览 63提问于2021-02-01得票数 0
在Google的Cloud Spanner数据库中，joins是如何工作的？
连接查询的执行速度会很快吗？SQL(MySql、Oracle、MSSQL)和NewSQL(Cloud Spanner/TiDB/CockroachDB)有什么比较吗？
浏览 1提问于2017-03-25得票数 3
Spanner的文档表明，在Spanner的多区域配置中，每个读写区域都有两个读写副本。每个只读区域的只读副本数量是否有限制(计算除外)？
浏览 22提问于2019-10-02得票数 1
尝试使用gcloud CLI创建表时(使用扳手模拟器)
gcloud spanner databases ddl update db_name --instance=instance_name --ddl=$data
我试图添加一个check约束，其中$data的计算结果为：
CREATE TABLE my_table (
my_key STRING(36),
some_column STRING(100),
CONSTRAINT ck_my_table_some_column_enum CHECK (some_column = 'this' OR so
浏览 1提问于2021-08-31得票数 0
回答已采纳
Google Cloud Spanner建议我们避免将索引放在单调递增(非PK)列上，例如时间戳(https://cloud.google.com/spanner/docs/schema-design)，但我的规范要求按(单调递增)时间戳列进行查询。 我计划绕开这个限制，每隔1分钟将时间轴打包一次(即10:00:35 -> 10:00:00)。这在Google Cloud Spanner上能正常工作吗？
浏览 16提问于2020-07-02得票数 0
回答已采纳
1回答
我对很陌生。我理解hoe创建连接(DbClient)，并将其用于事务和executeQuery/突变。但我不清楚如何为云扳手创建ConnectionPooling --这里有SpannerOptions、Session/SessionPoolOptions。只是通过创造
SpannerOptions options = SpannerOptions.newBuilder().build();
Spanner spanner = options.getService();
DatabaseClient dbClient = spanner.getDatabaseClient
浏览 1提问于2018-12-30得票数 0
回答已采纳
2回答
尝试在gke pods中创建扳手客户端，但获得：
File "/usr/local/lib/python3.7/site-packages/google/cloud/spanner_v1/database.py", line 519, in run_in_transaction
with SessionCheckout(self._pool) as session:
File "/usr/local/lib/python3.7/site-packages/google/cloud/spanner_v1/pool.py", line 536, in
浏览 1提问于2020-10-06得票数 0
我将在我的网络项目中使用google云扳手数据库。所以我想安装作曲家。当我在cmd中运行composer安装命令时，它将显示以下消息。
Problem 1
- Installation request for google/cloud-spanner ^1.27.1 -> satisfiable by google/cloud-spanner[v1.27.1].
- google/cloud-spanner v1.27.1 requires ext-grpc * -> the requested PHP extension grpc is missing fro
浏览 3提问于2020-04-14得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
