jacob-mathison/doczyai-pipelines
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Activity

Fixed typo in sp

Browse Source
This commit is contained in:
Umang Mistry
2024-02-27 15:52:01 -06:00
parent f496c58771
commit ea7fec111e
2 changed files with 14 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
snowflake/scripts/training_interface/R__002_LOAD_TRAINING_RESULTS_SP.SQL
+6 -6
View File
@@ -10,7 +10,7 @@ BEGIN
procedure_name := 'LOAD_TRAINING_RESULTS'; procedure_name := 'LOAD_TRAINING_RESULTS';
call stg.log_audit(procedure_name, 'Section 1', 99, 'START'); call stg.log_audit(:procedure_name, 'Section 1', 99, 'START');
-- Create or replace stage with dynamic file name -- Create or replace stage with dynamic file name
EXECUTE IMMEDIATE 'CREATE OR REPLACE STAGE STG.TRAINING_RESULTS_STAGE EXECUTE IMMEDIATE 'CREATE OR REPLACE STAGE STG.TRAINING_RESULTS_STAGE
@@ -18,8 +18,8 @@ BEGIN
URL = ''s3://doczy-dev-infra-raw-data-ingestion/training_interface/' || :file_name || ''' URL = ''s3://doczy-dev-infra-raw-data-ingestion/training_interface/' || :file_name || '''
FILE_FORMAT = (FORMAT_NAME = ''STG.CSV_HEADER'');'; FILE_FORMAT = (FORMAT_NAME = ''STG.CSV_HEADER'');';
call stg.log_audit(procedure_name, 'Section 1', 99, 'END'); call stg.log_audit(:procedure_name, 'Section 1', 99, 'END');
call stg.log_audit(procedure_name, 'Section 2', 99, 'START'); call stg.log_audit(:procedure_name, 'Section 2', 99, 'START');
-- Copy command to load data -- Copy command to load data
COPY INTO STG.TRAINING_RESULTS FROM COPY INTO STG.TRAINING_RESULTS FROM
( (
@@ -40,17 +40,17 @@ BEGIN
FILE_FORMAT = (FORMAT_NAME = 'STG.CSV_HEADER') FILE_FORMAT = (FORMAT_NAME = 'STG.CSV_HEADER')
ON_ERROR = CONTINUE; ON_ERROR = CONTINUE;
call stg.log_audit(procedure_name, 'Section 2', 99, 'END'); call stg.log_audit(:procedure_name, 'Section 2', 99, 'END');
call stg.log_audit(procedure_name, 'Section 3', 99, 'START'); call stg.log_audit(:procedure_name, 'Section 3', 99, 'START');
INSERT INTO DOCZY_DEV.STG.DIM_AUDIT (AUDIT_SID, TABLE_NAME, SOURCE_FILE_NAME, LOAD_DATE, SOURCE_COUNT) INSERT INTO DOCZY_DEV.STG.DIM_AUDIT (AUDIT_SID, TABLE_NAME, SOURCE_FILE_NAME, LOAD_DATE, SOURCE_COUNT)
SELECT STG.AUDIT_SID.NEXTVAL, 'STG.TRAINING_RESULTS',* SELECT STG.AUDIT_SID.NEXTVAL, 'STG.TRAINING_RESULTS',*
FROM FROM
(SELECT DISTINCT METADATA$FILENAME, CURRENT_TIMESTAMP(), max(METADATA$FILE_ROW_NUMBER) from @DOCZY_DEV.STG.TRAINING_RESULTS_STAGE group by 1,2); (SELECT DISTINCT METADATA$FILENAME, CURRENT_TIMESTAMP(), max(METADATA$FILE_ROW_NUMBER) from @DOCZY_DEV.STG.TRAINING_RESULTS_STAGE group by 1,2);
call stg.log_audit(procedure_name, 'Section 3', 99, 'END'); call stg.log_audit(:procedure_name, 'Section 3', 99, 'END');
RETURN 'Setup, Load, and Audit Complete'; RETURN 'Setup, Load, and Audit Complete';
END; END;
snowflake/scripts/training_interface/R__003_LOAD_ATTEMPTS_SP.sql
+8 -7
View File
@@ -5,21 +5,21 @@ EXECUTE AS CALLER
AS AS
$$ $$
DECLARE DECLARE
prcedure_name varchar; procedure_name varchar;
BEGIN BEGIN
procedure_name := 'LOAD_ATTEMPT_LOGS'; procedure_name := 'LOAD_ATTEMPT_LOGS';
call stg.log_audit(procedure_name, 'Section 1', 99, 'START'); call stg.log_audit(:procedure_name, 'Section 1', 99, 'START');
-- Create or replace stage with dynamic file name -- Create or replace stage with dynamic file name
EXECUTE IMMEDIATE 'CREATE OR REPLACE STAGE STG.ATTEMPT_LOGS_STAGE EXECUTE IMMEDIATE 'CREATE OR REPLACE STAGE STG.ATTEMPT_LOGS_STAGE
STORAGE_INTEGRATION = dev_bucket_integration STORAGE_INTEGRATION = dev_bucket_integration
URL = ''s3://doczy-dev-infra-raw-data-ingestion/training_interface/' || :file_name || ''' URL = ''s3://doczy-dev-infra-raw-data-ingestion/training_interface/' || :file_name || '''
FILE_FORMAT = (FORMAT_NAME = ''STG.CSV_HEADER'');'; FILE_FORMAT = (FORMAT_NAME = ''STG.CSV_HEADER'');';
call stg.log_audit(procedure_name, 'Section 1', 99, 'END'); call stg.log_audit(:procedure_name, 'Section 1', 99, 'END');
call stg.log_audit(procedure_name, 'Section 2', 99, 'START'); call stg.log_audit(:procedure_name, 'Section 2', 99, 'START');
-- Copy command to load data -- Copy command to load data
COPY INTO STG.TRAINING_ATTEMPT_LOGS FROM COPY INTO STG.TRAINING_ATTEMPT_LOGS FROM
@@ -37,15 +37,16 @@ BEGIN
FILE_FORMAT = (FORMAT_NAME = 'STG.CSV_HEADER') FILE_FORMAT = (FORMAT_NAME = 'STG.CSV_HEADER')
ON_ERROR = CONTINUE; ON_ERROR = CONTINUE;
call stg.log_audit(procedure_name, 'Section 2', 99, 'END'); call stg.log_audit(:procedure_name, 'Section 2', 99, 'END');
call stg.log_audit(procedure_name, 'Section 3', 99, 'START'); call stg.log_audit(:procedure_name, 'Section 3', 99, 'START');
INSERT INTO DOCZY_DEV.STG.DIM_AUDIT (AUDIT_SID, TABLE_NAME, SOURCE_FILE_NAME, LOAD_DATE, SOURCE_COUNT) INSERT INTO DOCZY_DEV.STG.DIM_AUDIT (AUDIT_SID, TABLE_NAME, SOURCE_FILE_NAME, LOAD_DATE, SOURCE_COUNT)
SELECT STG.AUDIT_SID.NEXTVAL, 'STG.TRAINING_ATTEMPT_LOGS',* SELECT STG.AUDIT_SID.NEXTVAL, 'STG.TRAINING_ATTEMPT_LOGS',*
FROM FROM
(SELECT DISTINCT METADATA$FILENAME, CURRENT_TIMESTAMP(), max(METADATA$FILE_ROW_NUMBER) from @DOCZY_DEV.STG.TRAINING_RESULTS_STAGE group by 1,2); (SELECT DISTINCT METADATA$FILENAME, CURRENT_TIMESTAMP(), max(METADATA$FILE_ROW_NUMBER) from @DOCZY_DEV.STG.TRAINING_RESULTS_STAGE group by 1,2);
call stg.log_audit(procedure_name, 'Section 3', 99, 'END'); call stg.log_audit(:procedure_name, 'Section 3', 99, 'END');
RETURN 'Setup, Load, and Audit Complete'; RETURN 'Setup, Load, and Audit Complete';
END; END;