google-bigquery 相关问题

Google BigQuery是一款Google Cloud Platform产品，可使用SQL提供无人值守数据集的无服务器查询。 BigQuery提供多个读写流水线，并支持数据分析，从而改变企业分析数据的方式。

从外部表更新 BigQuery 表时出错

我有一个包含大约 200,000,000 行的 BigQuery 表。我有一个外部表，其中包含需要通过要更新的行的唯一 ID 来更新值的行，以及需要的字符串...

sql google-bigquery external-tables

回答 1 投票 0

从内部谷歌网站到bigquery的ETL

我正在内部 Google 网站上工作，以托管我公司的所有产品、项目和客户相关内容，以便销售和支持团队能够访问。 - 数据按照

google-bigquery google-sites

回答 1 投票 0

decodeURIComponent（编码） - 使用 BigQuery

我在Big Query中使用函数decodeURIComponent(encoded)来解码具有特定URL的搜索词，但有时会出现此错误例如，让我们采用这个特定的 URL - 'https://kockasho...

sql google-bigquery

回答 1 投票 0

Javascript URL 库无法在 bigquery UDF 中工作

使用bigquery，我需要提取URL的组成部分，例如主机名、查询参数、路径和片段。由于 bigquery UDF 支持 javascript，我发现了同样的 URL 库，它是 nat...

javascript google-bigquery bigquery-udf

回答 1 投票 0

BigQuery Transfer Service 不会从 S3 复制行

我创建了从 AWS S3 到 Google BigQuery 的 BigQuery 传输。它失败并出现以下错误，未找到与“gs://bqdts-amazon_s3-prod-eu-w5jetqct8ohvcjih85apf7gvkbibvbkcj9...

amazon-web-services amazon-s3 google-cloud-platform google-bigquery data-transfer

回答 3 投票 0

如何通过循环变量在dbt中多次运行SQL模型？

我在 dbt (test_model) 中有一个模型，它在配置中接受地理变量（zip、州、地区）。我想通过每次循环变量来运行模型三次

sql google-bigquery jinja2 dbt

回答 1 投票 0

通过java spring boot上传Bigquery 400错误csv

我正在尝试使用 spring-boot java 将 csv 文件上传到 bigquery 我收到 400 条无效数据 public void uploadToBigQuery（文件csvFile，字符串表，布尔覆盖，列表我正在尝试使用 spring-boot java 将 csv 文件上传到 bigquery 我收到 400 条无效数据 public void uploadToBigQuery(File csvFile, String table, boolean overwrite, List<Pair<String, String>> columns) { log.info("Upload CSV file [{}] to BigQuery table [{}/{}]", csvFile.getPath(), dataSetName, table); try { // Fields List<Field> fields = columns.stream() .map(c -> Field.of(c.getFirst(), StandardSQLTypeName.valueOf(c.getSecond()))) .collect(Collectors.toList()); TableId tableId = TableId.of(dataSetName, table); WriteChannelConfiguration writeChannelConfiguration = WriteChannelConfiguration .newBuilder(tableId) .setFormatOptions(FormatOptions.csv()) .setCreateDisposition(JobInfo.CreateDisposition.CREATE_IF_NEEDED) .setWriteDisposition(overwrite ? JobInfo.WriteDisposition.WRITE_TRUNCATE : JobInfo.WriteDisposition.WRITE_APPEND) .setSchema(Schema.of(fields)) .build(); // The location must be specified; other fields can be auto-detected. JobId jobId = JobId.newBuilder().setLocation(DATASET_LOCATION).build(); TableDataWriteChannel writer = bigQuery.writer(jobId, writeChannelConfiguration); // Write data to writer try (OutputStream stream = Channels.newOutputStream(writer)) { Files.copy(csvFile.toPath(), stream); } // Get load job Job job = writer.getJob(); job = job.waitFor(); System.err.println("BigQuery job error: " + job.getStatus().getError().toString()); System.err.println("Full error: " + job.getStatus()); JobStatistics.LoadStatistics stats = job.getStatistics(); log.info("Wrote {} records to BigQuery table [{}/{}]", stats.getOutputRows(), dataSetName, table); } catch (IOException | InterruptedException | BigQueryException ex) { log.error("Error occured during writing of file to BigQuery", ex); } } 但出现以下错误 2024-07-04T23:28:06.389+05:30 INFO 32704 --- [ main] c.google.api.client.http.HttpTransport : { "error": { "code": 400, "message": "Error: 3848323", "errors": [ { "message": "Error: 3848323", "domain": "global", "reason": "invalid" } ], "status": "INVALID_ARGUMENT" } } 为什么会出现此错误以及如何排除故障有同样的问题。对我来说，改变 JobId.newBuilder().setLocation("us") // copied from a code sample 到 JobId.newBuilder().setLocation("eu") // where my project is actually located 修正了错误。

google-bigquery

回答 1 投票 0

是否可以根据某种映射进行分组？

我在 BigQuery 中有一个表，我希望能够根据某种类型的映射文件进行分组，例如，如果我有以下内容产品代码国家销售量 AA1 我们 5 AA2 我们 10 AA1 英国...

sql mysql google-bigquery

回答 2 投票 0

是否可以根据 BigQuery SQL 中的某种映射进行分组

我在 BigQuery 中有一个表，我希望能够根据某种类型的映射文件进行分组，例如，如果我有以下内容产品代码国家销售量 AA1 我们 5 AA2 我们 10 AA1 英国...

sql mysql google-bigquery

回答 1 投票 0

BigQuery 中每个月的第一个星期三和最后一个星期四

我希望从每月的第一天开始拉每个月的第一个星期三。选择案件当latestRefreshTime => ***每个月的第一个星期三*** 那么“最新” W...