decode udf

macros/streamline/configs.yaml.sql

@@ -157,5 +157,17 @@
     HANDLER = 'transform'
   sql: |
     {{ fsc_utils.create_udf_transform_logs() | indent(4) }}
+
+- name: {{ schema }}.udf_base58
+  signature:
+    - [input, STRING]
+  return_type: TEXT
+  options: |
+    LANGUAGE PYTHON
+    RUNTIME_VERSION = '3.8'
+    HANDLER = 'base58_decode_handler'
+  sql: |
+    {{ fsc_utils.create_udf_base58() | indent(4) }}
+
 {% endmacro %}
 

macros/streamline/functions.py.sql

@@ -177,4 +177,17 @@ def transform(events: dict):
     except:
         return events
 
+{% endmacro %}
+
+{% macro create_udf_base58() %}
+
+def base58_decode_handler(input):
+    if input is None:
+        return None
+    try:
+        decoded_bytes = base58.b58decode(input)
+        return decoded_bytes.decode('utf-8')
+    except Exception as e:
+        return str(e)
+        
 {% endmacro %}