Forum Discussion

mohammedjs12's avatar
mohammedjs12
New Contributor
2 years ago
Solved

Decrypt a column and load it to Snowflake table

Hi Team, I have a requirement where i need to decrypt a column coming from a snowflake table. Column value present in source table is already in encrypted form.  I used below approaches but none ac...
alchemiz's avatar
alchemiz
Contributor III
3 years ago

Hi Kuya,

Good day, I had a similar requirement before and I took the path in using the ultra task high availability api

Snaplex must have at least one node setup as a feed-master

  • Design an ultra pipeline that will serve as a wrapper to the child pipeline
  • Create ultra task for the pipeline wrapper

** Requirement was to send a JSON payload, the pipeline wrapper will be accepting JSON content-type by invoking REST Post from the pipeline runner

With ultra task, this pipeline can be upscale depending from your requirement (ultra task instance) with high availability for request to be served (max in flight)

Attached PoC pipelines

Runner - main pipeline that will invoke the ultra task pipeline
Runner_2022_09_04.slp (26.1 KB)

Do Something - the child pipeline will be executed
Do Something_2022_09_04.slp (5.3 KB)

open_api_save_random_image - the ultra pipeline (can also be the child pipeline)
open_api_save_random_image_2022_09_04.slp (22.5 KB)

Ultra task instance was set to 3

Hope this helps

Thanks,
EmEm