如何在Snowflake DB中查找挂起的任务？
Snowflake DB是一种云原生的数据仓库解决方案，它提供了强大的数据存储和分析能力。在Snowflake DB中查找挂起的任务可以通过以下步骤完成：
- 登录到Snowflake DB的管理控制台。你可以使用Snowflake提供的Web界面或者命令行工具进行登录。
- 在控制台中，选择你要查询的Snowflake DB实例。
- 在实例的概览页面或者菜单中，找到"任务"或者"查询"相关的选项。不同的控制台界面可能有所不同，但通常会提供类似的功能。
- 进入任务或查询页面后，你可以看到当前正在运行的任务列表。在这个列表中，你可以查找到挂起的任务。
- 如果你想查找特定的挂起任务，可以使用过滤器或者搜索功能来缩小结果范围。你可以根据任务名称、状态、运行时间等条件进行过滤。
- 一旦找到挂起的任务，你可以点击任务的详细信息来获取更多相关信息。这些信息可能包括任务的执行计划、日志、错误信息等。
在Snowflake DB中查找挂起的任务可以帮助你监控和管理数据仓库的运行情况，及时发现和解决任务执行中的问题。对于Snowflake DB的用户来说，这是一个重要的操作，可以提高数据分析和处理的效率。
腾讯云提供了类似的云原生数据仓库解决方案，称为TencentDB for Snowflake。它基于Snowflake DB的架构，提供了与Snowflake DB类似的功能和性能。你可以通过访问腾讯云的官方网站了解更多关于TencentDB for Snowflake的信息：https://cloud.tencent.com/product/tiup
请注意，本回答中没有提及亚马逊AWS、Azure、阿里云、华为云、天翼云、GoDaddy、Namecheap、Google等流行的云计算品牌商，以遵守问题要求。
相关·内容
1回答
气流中外部连接的连接池
、、、、
我试图找到一种方法，连接池管理外部连接创建的气流。
气流版本: 2.1.0
Python版本: 3.9.5
气流数据库: SQLite
创建外部连接: MySQL和雪花
我知道airflow.cfg文件中有一些属性
sql_alchemy_pool_enabled = True
sql_alchemy_pool_size = 5
但是这些属性是用来管理气流内部DB的，在我的例子中，这是SQLite。
我有很少的任务是读取或写入MySQL和雪花的数据。
snowflake_insert = SnowflakeOperator(
task_id='insert_sn
浏览 4提问于2021-06-14得票数 4
回答已采纳
有没有办法在websphere application serve中配置雪花连接池。我在server.xml文件中尝试了下面的配置。但不起作用。
<dataSource id="SnowflakeDataSource" jndiName="jdbc/BM_SF" type="javax.sql.DataSource">
<properties db="abcd" schema="_TARGET" URL="jdbc:snowflake://adpdc_cdl.us-east-1.priva
浏览 22提问于2021-02-23得票数 0
回答已采纳
2回答
我正在尝试从本地独立的融合Kafka主题连接到Snowflake表。我通过ksqldb使用以下连接器配置。
CREATE SINK CONNECTOR `snowflake_sink` WITH(
"name"='snowflake_sink',
"tasks.max"='1',
"connector.class"='com.snowflake.kafka.connector.SnowflakeSinkConnector',
"topics"='USERPROFILE'
浏览 0提问于2020-08-30得票数 2
我从Python连接到时遇到了一个奇怪的行为。如果我从SnowFlake检索的行数较少，那么Python程序就会成功退出，但如果我试图检索超过200K的行数，它肯定会挂起。我百分之百确定我的机器没有问题，因为我能够从Postgres等其他类型的数据库系统中检索500万到1000万行。
我的Python环境是Python3.6，我使用以下版本的库：-> SQLAlchemy 1.1.13，snowflake-connector-python 1.4.13，snowflake-sqlalchemy1.0.7，
下面的代码打印总行数并关闭连接。
from sqlalchemy import c
浏览 2提问于2018-01-26得票数 2
最近，微软在ADF中推出了针对数据流的雪花连接。有没有办法在ADF中打开下推优化，以便如果我的源和目标是Snowflake only，那么它应该触发snowflake中的查询来执行任务，而不是从snowflake环境中提取数据。就像一个普通的ELT过程，而不是ETL。 如果你需要更多的澄清，请告诉我。
浏览 12提问于2020-09-04得票数 0
我正在使用一个Snowflake存储过程，它将采用从一个数据库到另一个数据库的视图。我在努力 var sqlCommand = `
SELECT a.OBJECT_NAME, a.OBJECT_SCHEMA, a.OBJECT_TYPE, d.VIEW_DEFINITION
FROM VIEW_OBJECT_LIST a
INNER JOIN DB_DEV.INFORMATION_SCHEMA.VIEWS d ON a.OBJECT_NAME = d.TABLE_NAME AND a.OBJECT_SCHEMA = d.TABLE_SCHEMA
I
浏览 33提问于2020-10-29得票数 0
我正在尝试将报告数据库从Azure SQL服务器传输到Snowflake。 您能给我一些提示，并指导我如何使用最好的工具来自动化这个过程吗？ 我们的Azure数据库每1小时更新一次，所以我需要在Snowflake中传输数据并相应地更新它。 提前感谢您的指导。
浏览 32提问于2021-07-14得票数 1
回答已采纳
1回答
每次我尝试使用.NET 6中的Snowflake.Data NuGet包连接到雪花数据库时，都会在120秒后超时。我尝试过使用连接字符串中所有正确的凭据，以及所有不正确的凭据。无论是什么反应，都是一样的：
[2022-06-26T21:05:06.742Z] Snowflake.Data.Client.SnowflakeDbException (0x80004005): Error: Snowflake Internal Error: Unable to connect SqlState: 08006, VendorCode: 270001, QueryId:
[2022-06-26T21:0
浏览 44提问于2022-06-26得票数 0
回答已采纳
由于时间和技术的限制，我对Snowflake on Azure有以下ETL要求，并希望实现最简单的解决方案。 要求： 每天将CSV数据(仅几MB)从Azure Blob Storage加载到Snowflake Warehouse到临时表中。在Snowflake本身中转换上面加载的数据，其中转换仅限于几个连接和聚合，以获得一些度量。最后，将这些数据放入同一个Snowflake DB中的Datamart中的最终表中。最后，使用调度或使用基于事件的触发器(即，在文件到达Blob Store时立即启动的步骤)自动执行上述流水线。 约束条件： 我们不能使用Azure数据工厂来实现这个最简单的设计。我们
浏览 23提问于2020-12-08得票数 0
我们使用DMS从SQL Server中获取数据并将其加载到S3存储桶中，之后数据最终使用Snowpipe加载到Snowflake DB中进行完整加载。
现在，为了让雪花管道知道S3存储桶中有新的数据，文件名需要与上一个不同。我尝试了所有可用的任务设置选项(DROP_AND_CREATE、DO_NOTHING、TRUNCATE)，以使文件名不同，但仍然不起作用。它将文件名加载为LOAD00000001.csv
在文档中，它显示文件名将是递增的(例如，LOAD00000001.csv，LOAD00000002.csv.以此类推)，但这并没有发生。这就是为什么雪管无法注册更改的原因。
有人能帮帮忙
浏览 0提问于2018-08-16得票数 1
1回答
我们有一个内部网站，我们使用PHP7.2并使用PDO连接到多个数据库。一个要连接的数据库是Snowflake，对于它，我们使用它的PDO驱动程序(参见https://github.com/snowflakedb/pdo_snowflake)，并通过我们的web代理连接。 到目前一切尚好。 但是，一旦PDO对象被赋给一个新的变量(无论是作为值还是引用)，执行就会暂停5分钟，然后继续执行。请参见下面的示例： 快速:不重新分配PDO对象： putenv("http_proxy=http://ourproxy:80");
putenv("https_proxy=http://
浏览 9提问于2020-01-07得票数 0
2回答
我每天使用node js脚本将我的mongo DB数据同步到snowflake。因此，如果snowflake中已经存在一行，那么我想用新数据替换该行，或者如果snowflake中不存在该行，那么我想插入一个新行。此外，我还想对大量数据执行此操作。 那么有没有办法在snowflake中做批量插入呢？如果没有，那么实现这一目标的最佳方法是什么？ 该表可能有数百万行，将来可能会达到数十亿行。
浏览 14提问于2021-08-02得票数 1
回答已采纳
在我的cypress测试中，我在从process.env文件中获取变量值时遇到了一个问题。我试着这样做：https://docs.cypress.io/guides/guides/environment-variables#Option-5-Plugins，但当我尝试使用进程环境文件中的变量时，我得到了未定义的错误 我的index.js文件： const { preprocessTypescript } = require('@nrwl/cypress/plugins/preprocessor');
require('dotenv').config();
浏览 56提问于2021-05-10得票数 0
回答已采纳
2回答
我正在尝试连接snowflake数据库，但它显示在赋值之前引用了局部变量'cursor‘。我是不是在代码中遗漏了什么？ 以下是错误的屏幕截图： ? 下面是我的代码： def Source_database(self, source):
try:
print('######################################Cursor creation on database#################################')
if source['sy
浏览 34提问于2020-11-09得票数 0
回答已采纳
在SnowFlake中，是否有任何选项可以在存储过程中并行执行sql语句？我有一个存储过程(如下所示)，它包含35条sql语句，这些语句按顺序运行。我们计划减少时间，考虑并行执行所有这些。
实现这一目标的最佳方法是什么？(我所能想到的就是创建35个存储过程，并同时从一个调度程序调用所有这些存储过程)。想看看有没有更好的SnowFlake特性来实现这一点？
create or replace procedure SP_TEST()
returns string
language javascript
execute as CALLER
as
$$
try {
浏览 5提问于2020-10-07得票数 2
2回答
我想为雪花表发出一个DESC TABLE SQL命令，并使用Azure，但我不太清楚！我没有任何错误，但我也没有得到任何结果。下面是我使用的Python代码：
options_vcp = {
"sfUrl": snowflake_url,
"sfUser": user,
"sfPassword": password,
"sfDatabase": db,
"sfWarehouse": wh,
"sfSchema": sch
}
sfUtils = sc._jvm.net.sn
浏览 7提问于2022-07-01得票数 1
回答已采纳
因此，我使用了MongoDB 6.0 (以及python中的马达驱动程序)，例如，我有这样的代码：
money = 4.92
from_snowflake = "19251"
await db["bank"].update_one({"snowflake": str(from_snowflake)}, {"$inc": {"balance": -float(money)}})
假设db中"balance“字段的当前值为5.91，当我希望它为0.99时，最终值将为0.9900000000000002。
我能
浏览 17提问于2022-08-19得票数 0
回答已采纳
2回答
我使用Python雪花连接器将JSON文件放入雪花阶段，然后复制到将JSON插入到表中。
这是我的密码：
import snowflake.connector
snowflake_conn = snowflake.connector.connect(
user=sf_user,
password=sf_password,
account=sf_account
)
role_init = "USE ROLE ELT_ROLE"
wh_init = "USE WAREHOUS
浏览 4提问于2022-01-26得票数 0
回答已采纳
1回答
我正在尝试将Power连接到新创建的雪花帐户上的snowflake_sample_data模式。Power能够查看仓库、表和列，我能够在它们之间创建关系。但是，当创建可视化(或在"Get数据“步骤中预览数据)时，我收到的错误是”仓库SNOWFLAKE_SAMPLE_DATA被挂起“。
仓库不会挂起，因为我能够对它运行查询。此外，我执行了“显示仓库”，并看到有0座仓库被暂停。
我的默认用户SYSADMIN能够对仓库执行查询。
浏览 5提问于2020-12-30得票数 0
1回答
我在Snowflake中有一个任务，它通过调用一个存储过程来执行。我希望在任务失败时收到电子邮件通知。Snowflake可以做到这一点吗？我见过一个“通知集成”对象，但我不确定如何使用它。
浏览 0提问于2021-06-12得票数 0
当用户使用AD帐户从Power BI服务门户登录时，我们如何在snowflake DB中获取用户名 我们是否可以从Snowflake DB获取Azure AD用户详细信息，以便从Power BI服务进行登录 选择Current_USER
浏览 27提问于2020-10-20得票数 0
我正在使用python连接器部署sql create table脚本到snowflake使用snowchange，并且我的参数在CLI中被正确传递。不知道为什么，但我在运行命令时收到此错误。因为变量被正确声明了。 sql脚本： 创建或替换表{{ db_raw }}.schemaname.TEST1 ( TABLENAME VARCHAR(100)，SOURCE_SYS VARCHAR(100)，SCHEMA_NAME VARCHAR(100) )；我的脚本如下所示。 pip install --升级雪花连接器-python python $(System.DefaultWorkingDire
浏览 9提问于2021-07-06得票数 0
我有下面的密码。
terraform {
required_providers {
snowflake = {
source = "chanzuckerberg/snowflake"
version = "0.22.0"
}
}
}
provider "snowflake" {
alias = "sys_admin"
role = "SYSADMIN"
username = "tf-snow"
private_key_path =
浏览 22提问于2022-03-08得票数 1
回答已采纳
我们正在尝试从亚马逊网络服务S3 (外部阶段)获取数据，并将其加载到雪花内部阶段。Snowflake应该作为我们的数据湖，可以减少我们从AWS使用的存储量。有没有内置的功能可以从外部stage -->内部stage传输数据？ 目标是将数据加载到内部Snowflake阶段，然后从AWS中删除数据。我们希望Snowflake成为数据湖。
浏览 49提问于2020-07-28得票数 0
1回答
我有一个简单的dag (从mysql db获取参数)(就像sql，subject)，然后我有一个函数创建报告并发送到特定的电子邮件。
这是代码片段。
def s_report(k,**kwargs):
body_sql = list2[k][4]
request1 = "({})".format(body_sql)
dwh_hook = SnowflakeHook(snowflake_conn_id="snowflake_conn")
df1 = dwh_hook.get_pandas_df(request1)
df2 = df1.to_html()
body_
浏览 3提问于2022-11-28得票数 0
我试图创建一个卡夫卡连接器从卡夫卡到雪花使用卡夫卡到雪花部分的这个。
下面是我开始的连接配置的完整示例，包含在一个curl请求中。如您所见，它多次引用${file:/data/credentials.properties:ENV_VAR_NAME}以获取envars：
curl -i -X PUT -H "Content-Type:application/json" \
http://localhost:8083/connectors/sink_snowflake_01/config \
-d '{
"connector.cla
浏览 7提问于2022-01-12得票数 0
我是snowflake的新手，我必须将数据从现有的视图加载到Snowflake中的表中，而且还需要安排它每天运行-增量。
如何在snowflake.Suggestions中实现它是必需的。
浏览 4提问于2021-07-16得票数 0
日安，
我使用雪花文档中的示例代码来连接到它：
sfparams = {
"sfURL": "SOME_URL",
"sfUser": "SOME_USER",
"sfPassword": "SOME_PASSWORD",
"sfDatabase": "SOME_DB",
"sfSchema": "SOME_SCHEMA",
"sfW
浏览 15提问于2022-02-22得票数 0
Snowflake Python Connector仅适用于使用CREATE user命令创建的用户，似乎不适用于托管阅读器帐户。 在WebUI上： CREATE MANAGED ACCOUNT python_reader_acct ADMIN_NAME = reader_1, ADMIN_PASSWORD = 'reader_pwd', TYPE = READER; 在Python上： import snowflake.connector
ctx = snowflake.connector.connect(
user='reader_1',
浏览 40提问于2021-02-12得票数 0
我试过用液基工具来制作雪花数据库。它都在使用模式名称在所有大写(大写)中的位置。但是液化基并没有找到我的模式中的任何一个混合案例，例如(This_Schema)。
我试过把这个放进去，但没帮上忙。
<defaultSchemaName>This_Schema</defaultSchemaName>
POM.XML配置示例：
<driver>net.snowflake.client.jdbc.SnowflakeDriver</driver>
<url>jdbc:snowflake://${env.
浏览 3提问于2019-10-11得票数 0
回答已采纳
我通过命令pip3 install snowflake-connector-python[pandas]==2.3.3 asn1crypto==1.3.0 --user安装了snowflake连接器
我尝试通过以下方式连接：
from snowflake import connector
con = connector.connect(
host='.snowflakecomputing.com',
user='THE USER I USE FOR LOGGING IN TO MY
浏览 0提问于2020-10-07得票数 1
2回答
要求：
我正在使用以下3种数据格式：
df1 -数据处理前表中没有记录的查询结果
df2 -数据处理后表中没有记录的查询结果
df =合并df1和df2
代码：
from datetime import datetime,timedelta
from airflow import DAG
from airflow.contrib.operators.snowflake_operator import SnowflakeOperator
from airflow.operators.email_operator import EmailOperator
from airflow.operator
浏览 7提问于2021-09-30得票数 0
1回答
我正在尝试在Flyway中使用Snowflake JDBC驱动程序。我在Flyway核心版本的jdbc，并安装了雪花0.5.1驱动程序版本3.12.17。调试时，我可以手动连接到Snowflake，方法是： DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD); 但是当我尝试像这样设置Flyway数据源时： flyway.setDataSource(DB_URL, DB_USER, DB_PASSWORD); 我得到以下错误： Unable to autodetect JDBC driver for url: jdbc:snowf
浏览 40提问于2021-02-04得票数 1
回答已采纳
1回答
我尝试通过external browser身份验证连接到snowflake。我的连接字符串看起来像jdbc:snowflake://host/?allowMultiQueries=true&db=MY_DB&warehouse=MY_WARE&authenticator=externalbrowser&user=USER&，但是授权表单总是问我用户名？ ? 我没有找到解决这个问题的办法。第二个问题： 如何修改此表单并在此表单上添加密码
浏览 27提问于2019-09-20得票数 1
我正在尝试用.Net雪花数据为ADF构建一个雪花连接器，但是在生成测试由于用户和密码错误而失败后，我正在使用天蓝色上的雪花，有人建议我是否需要在parameter.json文件中添加更多的配置，请找到下面的错误。
在没有密码测试的情况下已经尝试过。
错误消息: Snowflake.Data.Client.SnowflakeDbException :指定了不正确的用户名或密码。堆栈跟踪:在Snowflake.Data.Client.SnowflakeDbConnection.Open() in D:\LululemonResources\VS\snowflake-connector-net-
浏览 4提问于2019-07-26得票数 0
1回答
有没有可能对来自Spark的所有查询使用一个事务？据我所知，事务不受支持。然而，最近我在我们的Spark (pyspark)作业中遇到了以下代码，它试图使用雪花事务：
run_snowflake_query(sfOptions, "BEGIN TRANSACTION;")
run_snowflake_query(sfOptions, prep_query_1)
run_snowflake_query(sfOptions, prep_query_2)
df.write.format(SNOWFLAKE_SOURCE_NAME).options(**
浏览 2提问于2021-04-28得票数 0
1回答
Sqitch部署到雪花DW失败
、、、、
Sqitch部署命令失败，错误如下：
sqitch deploy 'db:snowflake://amrutmonu:PASSWORD@wea87235.us-east-1.snowflakecomputing.com/DEMO_DB?Driver=Snowflake'
错误：
向db:snowflake://amrutmonu:@wea87235.us-east-1.snowflakecomputing.com/DEMO_DB?Driver=Snowflake 250001 (08001)添加注册表的：未能连接到DB。验证帐户名称是否正确: wea“/root/bin/斯诺t
浏览 3提问于2019-11-26得票数 0
1回答
雪花、任务和会话变量问题
、、、
我在Snowflake with Task中遇到了执行存储过程的问题，而SP正在使用会话变量QUERY_TAG，我希望使用该变量进行日志记录。当任务执行SP时，我会得到这样的错误：“会话变量'$QUERY_TAG‘不存在”以调用者的身份执行我在哪里尝试设置QUERY_TAG (在第一个任务的前置代码中或在定义中)都没有关系。
任务和SP由我以SYSADMIN身份创建
当我在查询编辑器(Snowflake，DBeaver等)中执行SP时，它运行得很好，所以SP中没有编码错误。SET QUERY_TAG =‘一个很好的查询标记’调用TASK_SCHEMA.SP_TASK_ONE()
当我调
浏览 18提问于2019-11-01得票数 1
2回答
我想知道snowflake任务是否允许您从外部staged S3存储桶执行复制命令到目标snowflake表中，如下所示。 COPY INTO snowflaketable FROM @externalstage/tablename/ FILE_FORMAT = (FORMAT_NAME = CSV); 谢谢
浏览 26提问于2019-12-19得票数 0
回答已采纳
我正在使用私钥身份验证连接到Snowflake，并且无法使用Sqitch进行连接。当使用snowsql直接连接时，这是成功的。
我的连接字符串如下所示：
sqitch status -vvv db:snowflake://username@myaccount.snowflakecomputing.com/POC_DB?Driver=Snowflake;authenticator=SNOWFLAKE_JWT;priv_key_file=/Users/username/rsa_key.p8;priv_key_file_pwd=xxxxxx;warehouse=DEFAULT_WH;uid=user
浏览 5提问于2019-10-05得票数 1
我正在使用雪花jdbc，并试图通过传递无效的仓库名称并在默认仓库中创建表，从而在雪花中创建表。
String jdbcUrl = "jdbc:snowflake://<identifier>.snowflakecomputing.com?warehouse=invalid_warehouse&db=db&schema=schema&role=role";
Connection conn = null;
Statement st = null;
try {
conn = D
浏览 5提问于2022-07-12得票数 1
1回答
我试图将雪花集成到我的柏树测试中，但是在编译过程中它一直在抛出错误。错误：
Error: Webpack Compilation Error
./node_modules/vm2/lib/resolver-compat.js
Module not found: Error: Can't resolve 'async_hooks' in 'C:\snowflake\node_modules\vm2\lib'
resolve 'async_hooks' in 'C:\snowflake\node_modules\vm2\lib'
浏览 13提问于2022-11-24得票数 2
回答已采纳
1回答
火星雨-雪花无法从表中加载数据
、、、、
我正在尝试使用下面的代码使用火星雨胶查询雪花中的数据
from awsglue.transforms import *
from awsglue.utils import getResolvedOptions
from pyspark.context import SparkContext
from awsglue.context import GlueContext
from awsglue.job import Job
from py4j.java_gateway import java_import
SNOWFLAKE_SOURCE_NAME = "net.snowflake.s
浏览 2提问于2022-02-19得票数 1
回答已采纳
我想知道最大Excel文件大小，我们可以使用一个简单的ETL包加载到db中。如果文件大小取决于系统信任或资源，那么我们如何计算它？在我的例子中，我试图加载500+Mbs的excel文件。我的包甚至在试图映射列的时候也会挂起。
谢谢。
浏览 3提问于2016-11-04得票数 0
回答已采纳
在Snowflake中创建任务时，还必须传递用于执行的Virtual Warehouse。 CREATE [ OR REPLACE ] TASK [ IF NOT EXISTS ] <name>
WAREHOUSE = <string>
... 关于这个话题，我想知道后来有人丢弃Virtual Warehouse的情况。 DROP WAREHOUSE <name> 任务是否会启动并且查询失败(因为它没有关联的仓库)，或者任务甚至不会因为他的定义中缺少仓库而启动？ 我的预期是任务正在启动，但查询立即失败。 有关创建任务的更多信息：https://docs
浏览 29提问于2020-09-30得票数 0
回答已采纳
我的场景是我在亚马逊网络服务的S3平面文件中有数据。当新文件到达S3时，我使用SNS触发雪花管道。为了将数据从S3中的平面文件加载到Snowflake表中，我使用了Snow-pipe。那么，当通过Snow-pipe将数据从平面文件加载到snowflake表时，我是否可以对源数据进行数据验证和一些计算？如果我们有什么办法的话请帮帮我。提前谢谢。
浏览 0提问于2020-02-28得票数 0
1回答
我正在查询TABLE_SCHEMA、TABLE_NAME、CREATED、来自Snowflake信息模式的LAST_ALTERED列。风景。接下来，我想将该表与视图的行计数合并。下面是我在Snowflake中运行的查询，我的问题是我不知道如何将这两个表合并到一个表中？
注:我是雪花新手。请提供代码和解释。
提前感谢您的帮助！
查询1
SELECT TABLE_SCHEMA,TABLE_NAME,CREATED,LAST_ALTERED FROM DB.SCHEMA.VIEWS
WHERE TABLE_SCHEMA="MY_SHEMA" AND TABLE_NAME IN (&
浏览 1提问于2022-05-20得票数 1
回答已采纳
我正在使用"gosnowflake“驱动程序从Golang应用程序中查询Snowflake DB。雪花模式：- NAME STRING AGE整型LOCS数组
Golang代码：-
package main
import (
"database/sql"
"fmt"
"log"
"strings"
_ "github.com/snowflakedb/gosnowflake"
)
type Person struct {
Name strin
浏览 1提问于2018-10-27得票数 5
1回答
我想要创建一个视图，以显示活动和非活动任务的完整列表。有办法吗？
上下文:我正在进行一些自动报告，提醒我们失败的任务或不活动的任务。
CREATE OR REPLACE VIEW "DB"."PUBLIC"."SNOWFLAKE_TASK_LIST" COPY GRANTS AS
SHOW tasks IN "DEV"."PUBLIC";
给我一个错误:意外的“表演”
浏览 2提问于2020-05-12得票数 0
回答已采纳
我正在使用pyspark从snowflake读取数据。我在上面做了一些转换。我现在正在尝试将转换后的数据写回snowflake，但在尝试这样做时遇到了一些错误。我在这方面找不到太多的文档。如果你已经克服了这个问题，请分享我错过的东西。提前谢谢。
pyspark --> 2.3.2
python --> 3.6
snowflake spark connector --> spark-snowflake_2.11-2.7.0-spark_2.4.jar
snowflake jdbc --> snowflake-jdbc-3.12.9.jar
注意:我使用的用户与创建DB，S
浏览 0提问于2020-08-08得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
