Задайте для переменной значение current_timestamp, используя задачу и передав эту переменную другой задаче, чтобы создать таблицу - PullRequest
Новая
       8

Задайте для переменной значение current_timestamp, используя задачу и передав эту переменную другой задаче, чтобы создать таблицу

0 голосов
/ 04 марта 2020

Я пытаюсь создать таблицу из необработанного источника данных json и добавить в другой столбец ссылку на переменную, равную current_timestamp.

Вот мой код, я предполагаю, что мои задачи каким-то образом не работает правильно. Возможно, переменная не является глобальной и теряется после завершения задачи, или я неправильно ее настраиваю. 

-- task 3
create or replace task refresh_timestamp_payrollcompensation
warehouse = task_wh
after copy_pega_sales_payrollcompensation
as set update_timestamp = current_timestamp::timestamp_ntz;

-- task 4
Create or replace task normalize_pega_sales_payrollcompensation
    warehouse = task_wh
    after refresh_timestamp_payrollcompensation
    as create or replace table prod.pega_sales.payrollcompensation
    as select 
    value:Amount::float as Amount,
    value:ApprovalDate::timestamp as ApprovalDate,
    value:ApprovedBy::varchar as ApprovedBy,
    $update_timestamp as update_timestamp

    from payrollcompensation_raw_json, lateral flatten (input =>jsontext);

Моя следующая мысль, чтобы сделать переменную update_timestamp dynamici c, мне нужно как-то объединить task 3 & task 4. Пример) set update_timestamp = current_timestamp::timestamp_ntz команда с task 4.

Любой совет очень ценится,

...