获取Google Cloud transfer Job的状态
Google Cloud Transfer Job是Google Cloud提供的一项服务，用于在不同存储系统之间进行数据传输和同步。它可以帮助用户将数据从一个存储系统（如本地服务器、其他云存储服务等）迁移到Google Cloud存储服务中，或者将数据从Google Cloud存储服务传输到其他存储系统。
Google Cloud Transfer Job的状态可以通过以下步骤获取：
- 登录Google Cloud控制台：https://console.cloud.google.com/
- 在控制台顶部选择所需的项目。
- 在左侧导航栏中选择“存储”>“Transfer”。
- 在Transfer页面中，您可以看到所有已创建的Transfer Jobs列表。
- 找到您想要获取状态的Transfer Job，并点击其名称进入详情页面。
- 在详情页面中，您可以查看Transfer Job的当前状态。
Transfer Job的状态通常包括以下几种：
- 进行中（In Progress）：表示Transfer Job正在进行数据传输或同步。
- 已完成（Completed）：表示Transfer Job已成功完成数据传输或同步。
- 已暂停（Paused）：表示Transfer Job已被暂停，暂停后可以选择继续进行或取消。
- 已取消（Cancelled）：表示Transfer Job已被取消，取消后将不再进行数据传输或同步。
根据Transfer Job的状态，您可以根据实际需求采取相应的操作。例如，如果Transfer Job处于进行中状态，您可以等待其完成；如果Transfer Job处于已暂停状态，您可以选择继续进行或取消。
推荐的腾讯云相关产品：腾讯云对象存储（COS）。
腾讯云对象存储（COS）是腾讯云提供的一种高可用、高可靠、强安全性的云存储服务。它可以帮助用户存储和管理海量的非结构化数据，支持多种数据访问方式，并提供了丰富的数据处理和管理功能。
腾讯云对象存储（COS）的优势包括：
- 高可用性：腾讯云COS采用分布式存储架构，数据在多个地域和可用区进行冗余存储，保证数据的高可用性和可靠性。
- 强安全性：腾讯云COS支持数据加密传输和存储，提供访问控制和权限管理，保护用户数据的安全性。
- 弹性扩展：腾讯云COS可以根据用户的需求自动扩展存储容量和吞吐量，满足不同规模和业务需求。
- 丰富的功能：腾讯云COS提供了多种数据处理和管理功能，如数据备份、归档、转码、图片处理等，满足用户对数据的各种需求。
- 灵活的接入方式：腾讯云COS支持多种数据接入方式，包括API接口、SDK、命令行工具等，方便用户进行数据的上传、下载和管理。
更多关于腾讯云对象存储（COS）的信息，请访问腾讯云官方网站：https://cloud.tencent.com/product/cos
相关·内容
我想创建一个小型python程序(云函数)来创建、运行和删除一些GCP存储传输服务。
我可以创建一个GCP存储传输作业，如下所示
from google.cloud import storage_transfer
transfer_job_request = storage_transfer.CreateTransferJobRequest({
'transfer_job': {
'project_id': project_id,
'status': storage_transfer.TransferJo
浏览 12提问于2022-08-01得票数 0
回答已采纳
我正在使用google cloud transfer api的node.js实用程序将数据从s3存储桶传输到我的Google Cloud存储桶 #1
storagetransfer.transferJobs.create(request, function (err, response) 一旦它完成，我想继续一些功能。要检查传输作业的状态，有一个api #2
storagetransfer.transferOperations.get(request, function(err, response) 这需要 var request = {
// The name of the ope
浏览 11提问于2019-04-11得票数 1
回答已采纳
我试图在GCS桶上传输内容或公开可用的url。
为此，我使用了，它要求我执行两个步骤：
创建一个包含公共URLS.To 的列表的.tsv文件，创建传输(此处使用python )。
要启动脚本，我使用一个服务帐户，它在包含transfer.tsv文件的桶和接收器桶上都具有权限。
只有当transfer.tsv文件上传到互联网上打开的桶中时，我才能让它正常工作。
您是否知道是否可以将is放在安全的桶上，并允许创建传输的服务帐户？
到目前为止，我所有的尝试都产生了以下错误。
误差
PERMISSION_DENIED 1
https://storage.googleapis.com/my-p
浏览 4提问于2022-04-02得票数 1
回答已采纳
目前，我正在我们的基础设施中做一个小的重构。我项目的当前版本类似于以下内容:我正在尝试使用for_each来重用变量。
resource "google_cloud_scheduler_job" "job" {
name = "Create_All_Dossier_Summary"
description = "desc1"
schedule = "0 19 * * 1"
time_zone = "America/Sao_Pau
浏览 6提问于2021-12-06得票数 3
回答已采纳
2回答
云函数是否有方法确认数据流作业是否成功？？
我尝试过的云功能：
const google = require('googleapis');
exports.statusJob = function(event, callback) {
const file = event.data;
if (file.resourceState === 'exists' && file.name) {
console.log(file.name);
console.log(event.data);
google.auth.getApp
浏览 3提问于2017-04-27得票数 2
我尝试使用应用程序接口将文件从亚马逊S3传输到谷歌云存储。我在GCP控制台上成功完成了此操作，但当我使用服务帐户凭据编写Python脚本时，我得到了HttpError 403 when requesting https://storagetransfer.googleapis.com/v1/transferJobs?alt=json returned "The caller does not have permission
此外，我的服务帐户已经是存储对象管理员。
我正在使用的脚本
import google.auth
import google_auth_httplib2
impor
浏览 4提问于2018-12-07得票数 5
在将JSONL文件加载到BigQuery中时，如何检索与验证错误有关的更多信息？(问题不在于解决这个问题)
示例代码：
from google.cloud.bigquery import (
LoadJobConfig,
QueryJobConfig,
Client,
SourceFormat,
WriteDisposition
)
# variables depending on the environment
filename = '...'
gcp_project_id = '...'
dataset_name =
浏览 13提问于2022-02-01得票数 2
回答已采纳
我试图运行一个存储传输作业，将文件从起始位置桶复制到目标位置的存储桶。
以下代码无法将启动桶文件重写到目标桶。
import datetime
import sys
import time
import googleapiclient.discovery
from google.cloud import bigquery, storage
import json
import pytz
PROJECT_ID = 'myproject_id' # TODO: set this to your project name
FROM_BUCKET = 'source_
浏览 0提问于2018-05-17得票数 1
回答已采纳
我们能不能运行local_exec来执行在Terraform中有多个命令的bash文件？我试过[google_cloud_scheduler_job][1] resource "google_cloud_scheduler_job" "job" {
name = "test-job"
description = "test job"
schedule = "*/2 * * * *"
provisioner "local-exec" {
command = "${pa
浏览 27提问于2020-09-30得票数 0
当我执行这个Java代码时：
(注:字符串参数是虚拟示例)
package bigquery.test;
import java.io.FileInputStream;
import java.io.InputStream;
import com.google.auth.oauth2.GoogleCredentials;
import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.BigQueryOptions;
import com.google.cloud.bigquery.Job;
impor
浏览 6提问于2022-06-20得票数 0
回答已采纳
当使用bigquery data transfer将数据从S3移动到BigQuery中时，我间歇性地获得了成功(我实际上只看到过一次它的正确工作)。 成功之处： 6:00:48 PM Summary: succeeded 1 jobs, failed 0 jobs.
6:00:14 PM Job bqts_5f*** (table test_json_data) completed successfully. Number of records: 516356, with errors: 0.
5:59:13 PM Job bqts_5f*** (table test_j
浏览 34提问于2020-07-29得票数 0
我更改了程序的服务密钥，现在收到以下错误： com.google.cloud.bigquery.BigQueryException: Not found: Dataset test-123:flights was not found in location US
at com.google.cloud.bigquery.spi.v2.HttpBigQueryRpc.translate(HttpBigQueryRpc.java:106)
at com.google.cloud.bigquery.spi.v2.HttpBigQueryRpc.getQueryResults(HttpBigQuer
浏览 42提问于2019-09-11得票数 1
我有一条数据流管道，在本地运行。目的是使用TEXTIO读取JSON文件，进行会话并将其加载到BigQuery中。根据这种结构，我必须在GCS中创建一个临时目录，然后使用该目录将其加载到BigQuery中。以前，我有一个数据模式错误，无法加载数据，请参阅。这个问题已经解决了。
因此，现在当我在本地运行管道时，它会将一个临时的JSON换行符分隔文件转储到GCS中。然后SDK提供了以下内容：
Starting BigQuery load job beam_job_xxxx_00001-1: try 1/3
INFO [main] (BigQueryIO.java:2191) - BigQuery l
浏览 0提问于2016-12-31得票数 0
回答已采纳
使用DirectPipelineRunner，我想在本地运行我的流水线，以便进行调试。我正在使用带有Java 8的SDK 1.9.0。
我的流水线从BigQuery读取一个表，转换一些字段，然后写回BigQuery。
在GCP上运行，即使用DataflowPipelineRunner运行器工作得非常好。然而，当我使用DirectPipelineRunner时，它只是不断地输出以下日志信息，而不做其他任何事情：
19:45:05,470 21866 [main] INFO com.google.cloud.dataflow.sdk.runners.DirectPipelineRunner -
浏览 25提问于2017-01-20得票数 0
我的GCP帐户中运行的Google云传输作业很少，它将数据从Azure传输到GCS存储桶。 根据本文档- https://cloud.google.com/storage-transfer/docs/reference/rest/v1/transferJobs/get?apix_params=%7B%22jobName%22%3A%22transferJobs%2F213858246512856794%22%2C%22projectId%22%3A%22merlincloud-gcp-preprod%22%7D，"get“方法可以获取作业的详细信息，如名称、描述、bucketName
浏览 19提问于2021-07-16得票数 0
回答已采纳
我有一个Dataflow项目，我将我的GoogleCloudOptions设置为：
google_cloud_options = options.view_as(GoogleCloudOptions)
google_cloud_options.project = my_settings.gcp_project_name
google_cloud_options.job_name = "{}-{}".format(my_settings.gcp_job_name, datetime.datetime.now().strftime("%y-%m-%d-%H-%M")
浏览 0提问于2018-03-08得票数 0
回答已采纳
2回答
我试着跑到下面-
select prd_cat, product_category from
(
select split( product_category,".") as prd_cat,product_category from
test_dataset.cosme_raw_table
where product_link = "XXX"
) as a
group by prd_cat,product_category;
当我使用BigQuery网络接口运行它时
浏览 0提问于2018-10-18得票数 1
回答已采纳
我正在尝试实现谷歌大查询。我不得不使用composer安装google库，因为它不适用于存储客户端和大型查询客户端。我的代码从云存储中读取文件，并将数据插入大查询表中。我收到以下错误和警告
PHP致命错误:带有消息‘选项20056’的未命名异常'Google\Cloud\Core\Exception\ServiceException‘不受此curl实现的支持。在/base/data/home/apps/s~xxx/1.402961109127965627/vendor/google/cloud/src/Core/RequestWrapper.php:241堆栈跟踪中：
0 /base
浏览 0提问于2017-07-27得票数 0
我试图使用Bigquery使用读取数据。
我的数据集不在美国位置，所以当我将数据集名称命名给库时，它会抛出一个错误，即数据集在美国位置中找不到，因为它默认在美国位置进行搜索。
我也试着用setLocation(“亚洲-东南1”)给出这个位置，但它仍然在美国找到。
这是我的代码片段：
val bigquery: BigQuery =BigQueryOptions.newBuilder().setLocation("asia-southeast1").build().getService
val query = "SELECT TO_JSON_STRING(t, true)
浏览 3提问于2020-01-07得票数 1
1回答
我在Google Cloud Functions上运行下面的python脚本，出现以下错误： Error: function terminated. Recommended action: inspect logs for termination reason. Details: name 'six' is not defined 下面是我的脚本： from google.cloud import bigquery
client = bigquery.Client()
def run(request):
csv_file = six.BytesIO(b"&
浏览 13提问于2019-12-13得票数 0
回答已采纳
1回答
我是GCP的新手。我在之后创建了一个Bigquery数据集。
现在，我正在尝试用PHP获取这些数据。为此，我跟踪了。
这是我的代码：
<?php
require_once __DIR__ . '/vendor/autoload.php';
use Google\Cloud\BigQuery\BigQueryClient;
use venor\google\cloud\Core\src\ExponentialBackoff;
$projectId = 'abcd';
$query = 'SELECT * FROM `abcd.TestData
浏览 1提问于2019-03-07得票数 0
我想处理云桶中的csv文件，并将它的数据插入到BQ表中。我发现了下面的代码，但我不知道如何为给定的表名实例化com.google.cloud.bigquery.Table
com.google.cloud.bigquery.Table table = null;
com.google.cloud.bigquery.Job job = table.load(FormatOptions.csv(), sourceUri);
com.google.cloud.bigquery.Job completedJob = job.waitFor(WaitForOption.c
浏览 1提问于2016-11-28得票数 0
回答已采纳
我正在尝试创建一个云函数，它将检查某些预定查询的状态，以便触发另一个进程。我正尝试在main.py中使用下面的代码
from google.cloud import bigquery
from google.cloud import bigquery_datatransfer
def extract_data(event, context):
transfer_client = bigquery_datatransfer.DataTransferServiceClient()
project_id = "projects/whr-asia-datalake-nonpro
浏览 0提问于2021-02-16得票数 0
目前，我在开发环境中部署这个Cloud资源时会遇到以下错误。
1. Step #1 - "Terraform plan": │ Error: Error creating Job: googleapi:
Error 403: The principal (user or service account) lacks IAM
permission "cloudscheduler.jobs.create" for the resource
"projects/whg-dev/locations/us-east1" (or th
浏览 7提问于2022-06-28得票数 0
2回答
谷歌云作业提交培训卡住了
、、、
您好，当我设置google cloud机器学习来训练神经网络时，突然我无法向google cloud提交作业。
没有错误，但是命令挂起了，没有做任何事情，而且我的实例正在运行.Here，命令如下：
gcloud ml-engine jobs submit training job9123 --runtime-version 1.0 --job-dir gs://dataset1_giorgaros2 --package-path trainmodule --module-name trainmodule.nncloud --region europe-west1 --config cloud
浏览 19提问于2018-06-11得票数 0
1回答
我对com.google.api.services有一些问题。我正在使用此版本的"BigQuery API v2 (修订版459)"：
实际上，"getConnectionProperties()“方法并不存在.这是一个完全的错误：
线程"main“中的com.google.api.services.bigquery.model.JobConfigurationQuery.getConnectionProperties()Ljava/util/List；异常:com.google.api.services.bigquery.model.JobConfigura
浏览 5提问于2020-12-30得票数 0
回答已采纳
我需要将这个查询的结果传输到BigQuery，如您所见，我解码了在云存储中获得的数据，创建了一个avro文件将其加载到一个BigQuery表中，但我收到了以下错误：
BadRequest Traceback (most recent call last)
<ipython-input-8-78860f4800c4> in <module>
110 bucket_name1 = 'gs://new_bucket/insert_transfer/*.avro'
111
-->
浏览 3提问于2019-11-26得票数 0
回答已采纳
我很难在红宝石客户端上使用(v0.22.2)。
我可以执行长期运行的作业，如果我使用
job.wait_until_done!
但这会将服务器锁定很长一段时间。
根据API文档，我真正需要的是操作名(Id)。
是否有任何方法从操作名称创建作业对象并以这种方式检索它？我似乎无法创建一个功能新的作业对象，比如使用@grpc_op中的id
我想做的是：
speech = Google::Cloud::Speech.new(auth_credentials)
job = speech.recognize_job file, options
saved_job = job.to_json #Or so
浏览 3提问于2017-08-31得票数 1
回答已采纳
我有一个应用程序，可以读取CSV文件并将其推送到BQ表，在执行下一个CSV文件之前检查该作业的状态，等等。当我的数据集在美国区域时，这种方法工作得很好，但是我们最近将数据集移动到了澳大利亚区域，现在我得到了 #error { :cause 404 Not Found { "code" : 404, "errors" : [ { "domain" : "global", "message" : "Not found: Job load-csv-job123", "reason" :
浏览 25提问于2020-09-22得票数 0
回答已采纳
1回答
我在编写python脚本时遇到了困难，该脚本从google云存储向加载或导出文件。
#standardSQL
import json
import argparse
import time
import uuid
from google.cloud import bigquery
from google.cloud import storage
dataset = 'dataworks-356fa'
source = 'gs://dataworks-356fa-backups/pullnupload.json'
# def load_data_from_g
浏览 2提问于2017-07-05得票数 0
回答已采纳
我们正在尝试的：
我们正在尝试运行一个云运行作业，它可以进行一些计算，还可以使用我们的自定义包来完成计算。云运行作业使用的是google-cloud-logging和python的默认日志包，如描述的。自定义python包还记录其数据(只将记录器定义为建议的)。
简单说明：
from google.cloud import logging as gcp_logging
import logging
import os
import google.auth
from our_package import do_something
def log_test_function():
SCO
浏览 3提问于2022-11-03得票数 0
我正在尝试仅将亚马逊S3中的特定文件导入到谷歌云服务中。
在中，上面提到的过程从Amazon源存储桶导入所有文件。
def main(description, project_id, day, month, year, hours, minutes,
source_bucket, access_key, secret_access_key, sink_bucket):
"""Create a one-off transfer from Amazon S3 to Google Cloud Storage."""
storagetransf
浏览 0提问于2017-06-15得票数 1
根据Google给出的例子，我按照指南(链接和代码)将CSV文件加载到BigQuery(BQ)表中。
现在，我想将几个文件添加到BQ中，并希望添加一个包含文件名的新列filename。
是否有方法添加带有默认数据的列？
// Import the Google Cloud client libraries
const {BigQuery} = require('@google-cloud/bigquery');
const {Storage} = require('@google-cloud/storage');
// Instantiate clients
浏览 1提问于2020-12-07得票数 2
回答已采纳
我正在尝试使用GCP Cloud Scheduler上的cron作业。我使用的是带有"GET“方法的HTTP目标。
我正在尝试发布消息到不一致的通道，但首先需要获得我的服务器webhook发送回给我的正文。CRON作业成功运行，但我找不到在GCP Cloud Scheduler上返回的webhook的正文。我也查过日志了，里面没有正文。以下是日志所包含的内容：
{
"insertId": "a06j1cfzy21xe",
"jsonPayload": {
"targetType": "HTTP
浏览 4提问于2020-08-11得票数 0
我们遇到了一个问题，在配置标准SQL时，发出BigTable外部表的查询时会出现dry_run = True错误。
这是意料之中吗？当使用遗留SQL或dry_run设置为false时，没有问题。
from google.oauth2.service_account import Credentials
from google.cloud.bigquery.client import Client
from google.cloud.bigquery.job import QueryJobConfig
creds = Credentials.from_service_account_file(
浏览 2提问于2018-04-18得票数 0
在运行下面的php脚本时，我得到了以下致命错误：
等待工作完成
**Fatal error: Uncaught Error: Call to undefined method
Google\Cloud\BigQuery\CopyJobConfiguration::*reload()*
in /opt/bitnami/apache2/htdocs/test.php:53 Stack trace: #0 [internal function]:
{closure}() #1 /opt/bitnami/apache2/htdocs/vendor/google/cloud/src/Core/E
浏览 2提问于2017-12-16得票数 1
回答已采纳
我正在尝试通过jupyter运行一个PySpark作业，我需要创建一个函数来运行该作业。我需要传递一个jar文件，我正在试图弄清楚如何做到这一点。我确实在上面找到了一些文档：https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#google.cloud.dataproc.v1.SubmitJobRequest https://cloud.google.com/dataproc/docs/reference/rest/v1beta2/HadoopJob 但是我不能确切地知道如何将URI添加到函
浏览 16提问于2019-10-07得票数 3
我正在对google存储执行一个提取查询，如下所示： job_config = bigquery.ExtractJobConfig()
job_config.compression = bigquery.Compression.GZIP
job_config.destination_format = (bigquery.DestinationFormat.CSV)
job_config.print_header = False
job_config.field_delimiter = "|"
extract_job = client.extract_table(
浏览 24提问于2021-06-16得票数 0
我正在尝试创建一个云函数来触发从大查询表到google云存储的导出。我阅读了下面的链接，并做了同样的事情。
请查看下面我在main.py中提供的内容
# Imports the BigQuery client library
from google.cloud import bigquery
def extract_data(request):
# Replace these values according to your project
project_name = "whr-asia-datalake-nonprod"
浏览 20提问于2021-02-13得票数 0
主要对象
一个python流管道，在该管道中，我从pub/sub读取输入。
在对输入进行分析之后，有两个选项可用：
如果x=1 ->插入
如果x=2 ->更新
测试
这不能使用apache函数完成，所以您需要使用BigQuery的0.25API来开发它(目前这是Google支持的版本)。
问题
插入的记录仍在BigQuery缓冲区中，因此update语句失败：
表上的UPDATE或DELETE语句将影响流缓冲区中不受支持的行。
代码
插入
def insertCanonicalBQ(input):
from google
浏览 0提问于2018-11-29得票数 1
在本地开发应用程序引擎服务器(以及生产应用程序引擎)上，我想运行一个脚本，其中包含大量查询相关代码，但是我得到了一个错误。我已经在堆栈溢出中访问了与此错误相关的所有答案，但没有发现任何可行的答案。下面是发生的代码和错误。提前感谢你宝贵的时间。
码
#!/usr/bin/python
from google.cloud import bigquery
client = bigquery.Client('myproject')
query = '(SELECT *FROM (SELECT *, ROW_NUMBER() OVER (PARTITION BY tb1.use
浏览 2提问于2017-12-22得票数 1
我正在尝试通过GCP中的Cloud Function触发计划查询。我试着学习了几个教程和示例，也浏览了文档，但是在新版本的google-cloud-bigquery-datatransfer==3.1.1中，我找不到任何说明正确过程的东西。
你可以在下面找到我当前的代码：
from google.cloud import bigquery_datatransfer_v1
def triggerQuery (parent, requested_run_time):
client = bigquery_datatransfer_v1.DataTransferServiceClient()
浏览 9提问于2021-05-24得票数 0
BigQuery支持将表数据导出到CSV。但是，我想将结果导出到xls。有什么方法导出XLS格式吗？
// Import the Google Cloud client libraries
const {BigQuery} = require('@google-cloud/bigquery');
const {Storage} = require('@google-cloud/storage');
const bigquery = new BigQuery();
const storage = new Storage();
async function ex
浏览 11提问于2022-03-21得票数 -1
回答已采纳
我试过测试云传输功能，它可以将对象从亚马逊网络服务的S3传输到GCS (作为一次性任务)，但我一直使用googleapiclient.errors.HttpError: <HttpError 400 when requesting https://storagetransfer.googleapis.com/v1/transferJobs?alt=json returned "Precondition check failed.">。
代码如下：
import argparse
import datetime
import json
from pprint impo
浏览 2提问于2018-04-13得票数 1
我们正在尝试使用node.js google_cloud sdk从google_cloud将数据加载到BigQuery中。下面是加载代码的一个片段：
//init Google Cloud storage
var gcs = require("@google-cloud/storage")({
projectId: bq_projectId,
keyFilename: "./" + keyfile
});
//init Google BigQuery
var bq = require("@google-cloud/bigquery")(
浏览 4提问于2017-05-19得票数 0
回答已采纳
jobs:
job1:
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v2
- name: Download Cloud SQL Auth Proxy
run: |
wget https://dl.google.com/cloudsql/cloud_sql_proxy.linux.amd64 -O cloud_sql_proxy
chmod +x cloud_sql_proxy
job2:
needs: job1
ru
浏览 9提问于2022-03-31得票数 2
回答已采纳
我使用以下Python代码从BigQuery中的一个表中删除了所有数据，当我在运行代码几秒钟后检查该表时，我发现该表现在是空的，因此删除肯定成功了。但是，作业状态仍然显示它处于运行状态。
from google.cloud import bigquery
import time
client = bigquery.Client()
job_config = bigquery.QueryJobConfig()
job_config.priority = bigquery.QueryPriority.INTERACTIVE
sql = """DELETE FR
浏览 3提问于2018-08-10得票数 1
回答已采纳
我一直使用google_cloud向big query提交作业，以便将文件提取到GCS，如下所示：
dataset = self.bqClient.dataset(self.website_id)
table = dataset.table(table_name)
job_name = str(uuid.uuid4())
job = self.bqClient.extract_table_to_storage(
job_name, table, destination)
job.destination_format = "NEWLINE_DELIMITED_JSON"
job.
浏览 2提问于2017-08-19得票数 0
回答已采纳
1回答
有三台机器，一台出版商，两位消费者。我正在用金刚向某台机器发布订单。这台机器是用巨蟒做消费者的。我想知道如何才能得到订单在publisher中已经完成或失败的结果。
如果订单不属于机器一号，我该怎么办？放了还是埋了？
python:使用者：
import beanstalkc
def get_beanstalk_data(conf):
beanstalk = beanstalkc.Connection(host='127.0.0.1',port=11300)
beanstalk.use('cloud')
beanstalk.watch(
浏览 5提问于2016-12-26得票数 0
回答已采纳
from google.cloud import bigquery
query = """ select * from emp where emp_name=@emp_name"""
query_params = [bigquery.ScalarQueryParameter('emp_name', 'STRING', 'name')]
job_config = bigquery.QueryJobConfig()
job_config.query_parameters = query_par
浏览 0提问于2018-06-07得票数 9
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
