Скачать или смотреть Snowflake Python Stored Procedure as In Line Code in Snowflake worksheet | in-depth intuition

This video explains how to write a stored procedure in Python. You can use the Snowpark library within your stored procedure to perform queries, updates, and other work on tables in Snowflake.

Prerequisite:
-----------------
Getting Started with Snowpark for Python on Snowflake
   • Getting Started with Snowpark for Python o...  

CSV Data Load from External Stage to Snowflake Table using Snowpark
   • Read CSV Data from External Stage & write ...  

Read Parquet Data from External Stage & write in Permanent Snowflake Table using Snowflake Snowpark
   • Read Parquet Data from External Stage & wr...  

Read Json Data from External Stage & write in Permanent Snowflake Table using Snowflake Snowpark
   • Read Json Data from External Stage , Flatt...  

Understanding Caller’s Rights and Owner’s Rights in Snowflake Stored Procedures
   • Understanding Caller’s Rights and Owner’s ...  

Documentation:
-------------------------------
https://docs.snowflake.com/en/sql-ref...

SQL Query:
------------------

drop database if exists ramu;
--Create Database
create database if not exists ramu;
--use the database
use ramu;



CREATE OR REPLACE PROCEDURE multiply_together(INPUT_NUMBER_1 int,INPUT_NUMBER_2 int)
RETURNS STRING
LANGUAGE PYTHON
RUNTIME_VERSION = '3.8'
PACKAGES = ('snowflake-snowpark-python')
HANDLER = 'multiplier'
AS
$$
def multiplier(session,a,b):
return a*b
$$;

call multiply_together(2,3);

call multiply_together(3,5);


CREATE OR REPLACE PROCEDURE reverse_string(INPUT_STR STRING)
RETURNS STRING
LANGUAGE PYTHON
RUNTIME_VERSION = '3.8'
PACKAGES = ('snowflake-snowpark-python')
HANDLER = 'reversal'
AS
$$
def reversal(session,a):
ms= a[::-1]
return ms
$$;


call reverse_string('ABC');

call reverse_string('BMHS');




CREATE OR REPLACE PROCEDURE retrieve_current_user_warehouse_schema()
returns string not null
language python
runtime_version = '3.8'
packages = ('snowflake-snowpark-python')
handler = 'retrieve_current_user_warehouse_schema'
as
$$
def retrieve_current_user_warehouse_schema(session):
return session.sql("select current_user,current_warehouse(),current_database(),current_schema()").collect()[0].asDict()
$$
;

call retrieve_current_user_warehouse_schema();


CREATE OR REPLACE PROCEDURE basic_metadata_command_to_table(
INPUT_METADATA_COMMAND STRING
, INPUT_DESTINATION_TABLE STRING
)
returns string not null
language python
runtime_version = '3.8'
packages = ('snowflake-snowpark-python')
handler = 'basic_metadata_command_to_table_py'
execute as caller
as
$$
def basic_metadata_command_to_table_py(snowpark_session, metadata_command: str, destination_table: str):

Read the command into a Snowflake dataframe
results_df = snowpark_session.sql(metadata_command)

Write the results of the dataframe into a target table
try:
results_df.write.mode("overwrite").save_as_table(destination_table)

return f"Succeeded: Results inserted into table {destination_table}"
except Exception as e:
return e
$$
;

create or replace table source_table( emp_no int,emp_name text,salary int, hra int ,Dept text);

INSERT INTO source_table VALUES (100, 'A' ,2000, 100,'HR'),
(101, 'B' ,5000, 300,'HR'),
(102, 'C' ,6000, 400,'Sales'),
(103, 'D' ,500, 50,'Sales'),
(104, 'E' ,15000, 3000,'Tech'),
(105, 'F' ,150000, 20050,'Tech'),
(105, 'F' ,150000, 20060,'Tech');

select * from source_table;


select * from hello_world;


Check this playlist for more Data Engineering related videos:
   • Demystifying Data Engineering with Cloud C...  

Apache Kafka form scratch
   • Apache Kafka for Python Developers  

Snowflake Complete Course from scratch with End-to-End Project with in-depth explanation--
https://doc.clickup.com/37466271/d/h/...

🙏🙏🙏🙏🙏🙏🙏🙏
YOU JUST NEED TO DO
3 THINGS to support my channel
LIKE
SHARE
&
SUBSCRIBE
TO MY YOUTUBE CHANNEL