我正在使用一个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
我们成功地将Oracle Data Integrator 12c从Oracle Cloud Infrastructure连接到Snowflake,但当我们运行利用ODI Knowledge Modules的映射时,我们看到批量数据通过单独的SQLID以小块的形式发送。有没有人有使用Oracle Data Integrator和Snowflake、跨云的经验?除了首先将记录写入文件并加载文件之外,还有关于如何一次处理更多记录的提示吗?我认为,这有点违背了目的。
我是加载数据到雪花使用外部阶段。此操作在存储过程中执行,并从雪花任务中调用该过程。过程使用“复制到查询”将数据加载到表中,然后检查验证错误。为了获得验证错误,我使用_last作为job_id。
用于将数据复制/加载到雪花表中的查询
COPY INTO conference_created_tmp FROM @conference_created_src/year=2021/month=04/day=15/hour=01/ ON_ERROR = 'SKIP_FILE'
用于获取验证错误的查询:
SELECT FILE as fileName, ERROR as error
FRO
尝试上载大小为100 in的csv,并在tmp中创建压缩文件后获得此错误。
data = sf_file_transfer_agent.result()
File "/apps/tools/python/python36/lib/python3.6/site-packages/snowflake/connector/file_transfer_agent.py", line 722, in result
"errno": ER_FAILED_TO_UPLOAD_TO_STAGE,
File "/apps/tools/python/p
我正在尝试将一个表从python中的Snowflake连接器更新为一个Snowflake表; update TABLE set X = 100 where Y = 'Applebee's' 为了转义Snowflake UI中的单引号,我将"where“子句的格式设置为 where Y = 'Applebee\'s' 还尝试了: where Y = 'Applebee''s' 然而,我尝试过的任何修复方法都不能成功地解决python中的这个错误。有没有一种方法可以在python中实现这一点,在Snowfla
我在snowflake过程中有一个用例,其中我有两个具有不同角色的数据库。我想从一个存储过程在这两个数据库的表中插入数据。我在其中一个数据库中创建了过程,该过程在该数据库中插入数据,但当我尝试在第二个数据库中插入数据时,它显示: SQL compilation error: Database 'SecondDB' does not exist or not authorized. 然后,我尝试在过程中插入第二个数据库之前使用查询来更改角色,如下所示: var SwitchToLoader = "use role SecondDbRole";
try {
sno
我有一个作业,当我运行它的时候-我得到了这个:
[ERROR] 11:47:54 org.talend.components.snowflake.runtime.SnowflakeRowStandalone- Query execution has
failed. Please validate your query.
net.snowflake.client.jdbc.SnowflakeSQLException: Execution error in store procedure
SP_GENERAL:
Numeric value '' is not recognize
我有一个依赖于会话变量的视图:
create or replace view test as
(
select getvariable('MY_VAR')::int as col1
) ;
我可以这样查询这个视图:
set MY_VAR=5;
select * from test; -- 5
set MY_VAR=6;
select * from test; -- 6
现在,我想从存储过程执行相同的查询:
create or replace procedure myproc()
returns VARCHAR
language javascript
我已经创建了一个雪花Java函数snowflake_email_validation,并试图从雪管道中调用该函数。
它将错误抛出如下:
用户定义的函数'SNOWFLAKE_EMAIL_VALIDATION‘在管道定义中是不允许的。
这是我的命令
create or replace pipe emailpipe auto_ingest=true as
copy into TGT_EMAIL_TABLE(EMAIL, IS_VALID)
from (select $1,snowflake_email_validation($1) from @s3_stage)
o
我试图在Azure database中使用Get元数据活动,以便获取blob文件名并将它们复制到Azure SQL数据库表中。我在Get元数据活动之后添加了存储过程活动。下面是我的新活动存储过程,我按照建议添加了参数,但是,我将名称更改为JsonData,因为存储过程需要这个参数。
这是我的存储过程。
/****** Object: StoredProcedure [dbo].[InsertDataJSON] Script Date: 10/14/2020 11:01:30 AM ******/
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFI