Category "snowflake-cloud-data-platform"

MWAA Airflow 2.0 in AWS Snowflake connection not showing

Snowflake is not showing in the connections dropdown. I am using MWAA 2.0 and the providers are already in the requirements.txt MWAA uses python 3.7 dont know i

Snowflake. How to check if the sub-array is presented in another array?

I want to check if all the items from one array are presented in another array. I've been looking through Snowflake docs but can't find any good approach. For e

How to calculate frequency percentages for a table using SQL?

Let's say I have some data as follows: ID data fingers rating 001 hello y 0 002 hello n 0 003 bye n 0 004 hell

Can we append a dataframe to snowflake table having some data, when some columns are same and some columns are different?

I have a dataframe which contains some columns and snowflake table is having some columns. Some columns are same and some columns are different between them. As

Executing Multiple Lines in a Snowflake Task

I created the task below and am having trouble getting it to execute all lines. It looks like it just does the first delete from productweekly_upload then compl

Snowflake Snowsight Marketplace: User's configured default role does not exist or not authorized

Trying to access Snowflake's marketplace (Trying to access Snowsight gives the same error message). when I log onto the legacy browser UI and click on "Data Mar

Snowflake Snowpipe - Email Alert Mechanism

I am planning to use Snowpipe to load data from Kafka, but the support team monitoring the pipe jobs needs an alert mechanism. How can I implement an alert mech

Storing the results from run query into a table in dbt

I am calling this store procedure in dbt. How do I store the results using a select statement into a temp table? {% set results= run_query('call mystoredproc()'

Data migration for .SQB files to Snowflake

I need to migrate .SQB files to Snowflake. I have a data relay where MSSQL Server database files are saved in .SQB format (Redgate) and available via sSTP with

How to connect Snowflake with PySpark?

I am trying to connect to Snowflake with Pyspark on my local machine. My code is as follows: from pyspark.sql.types import * from pyspark.sql import SparkSessio

How to find the number of rows for all views in a schema?

Sometimes I have access to schemas with hundreds of views (when using the Snowflake Data Marketplace). How can I find the number of rows for each of these views

When Migrating from SQL Server to Snowflake how do we migrate stored procedures

I am doing POC on Snowflake and exploring this product. I have a question: in SQL Server, we have 400-500 stored procedures and these stored procedures are get

How to change the export format in the Snowflake

Could you help me? I don't know how to get the result. I have to prepare the export file to the customer by strict structure from Snowflake. I suppose that the

Fuzzy Matching in SnowFlake like EDIT_DISTANCE_SIMILARITY

Do we have any function for name fuzzy matching like we have UTL_MATCHING.EDIT_DISTANCE_SIMILARITY in oracle. I have to find the difference at row level.

SQL compilation error: syntax error line 1 at position 7 unexpected 'ROWS'

When I run the below query from snowflake web UI, Here is the error message: select ROWS from "SNOWFLAKE"."ACCOUNT_USAGE"."METERING_HISTORY"; SQL compilation e

Snowflake Primary key using alter statement

when I was adding primary key to snowflake table I saw something weird. When I ran a query ALTER TABLE "TESTSCHEMA".table1 ADD PRIMARY KEY (ID); Above query wo

Partition by date in Snowflake procedure removing leading zeros from date

I am trying to partition the data from a Snowflake table and storing it as a parquet file in a S3 bucket. This partition allows me to store the data organised b

SNOWFLAKE - AZURE ACTIVE DIRECTORY Integration

I'm trying to integrate Azure Active Directory with Snowflake. I've set everything up as instructed in this document : https://docs.microsoft.com/en-us/azure/ac

Snowflake subquery

I have two tables. Transaction(ID, TERMINALID) and Terminal(ID, TERMINALID, EXPORT_DATE). The goal is to obtain for each row from Transaction table newest recor

django to snowflake connection and running ORM queries

I am looking to shift out of Postgres to SnowFlake as some of my features require run time analysis which is faster in Snowflake. I could only get the Python c