diff --git a/macros/create_evm_streamline_udfs.sql b/macros/create_evm_streamline_udfs.sql
new file mode 100644
index 0000000..6e4c3b0
--- /dev/null
+++ b/macros/create_evm_streamline_udfs.sql
@@ -0,0 +1,9 @@
+{% macro create_evm_streamline_udfs() %}
+    {% if var("UPDATE_UDFS_AND_SPS") %}
+        {% set sql %}
+        {{ create_udf_bulk_rest_api_v2_evm() }}
+        {{ create_udf_bulk_decode_logs() }}
+        {% endset %}
+        {% do run_query(sql) %}
+    {% endif %}
+{% endmacro %}
\ No newline at end of file
diff --git a/macros/streamline/udfs.sql b/macros/streamline/udfs.sql
index dc6cd33..e639692 100644
--- a/macros/streamline/udfs.sql
+++ b/macros/streamline/udfs.sql
@@ -20,4 +20,53 @@
     {% endset %}
     {{ log(sql, info=True) }}
     {% do adapter.execute(sql) %}
-{% endmacro %}
\ No newline at end of file
+{% endmacro %}
+
+
+{% macro create_udf_bulk_decode_logs() %}    
+    {{ log("Creating udf udf_bulk_decode_logs for target:" ~ target.name ~ ", schema: " ~ target.schema ~ ", DB: " ~ target.database, info=True) }}
+    {{ log("role:" ~ target.role ~ ", user:" ~ target.user, info=True) }}
+
+    {% set sql %}
+    CREATE OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_decode_logs(json object) returns array api_integration = 
+    {% if target.name == "prod" %} 
+        {{ log("Creating prod udf_bulk_decode_logs", info=True) }}
+        {{ var("API_INTEGRATION") }} AS 'https://{{ var("EXTERNAL_FUNCTION_URI") | lower }}bulk_decode_logs'
+    {% elif target.name == "dev" %}
+        {{ log("Creating dev udf_bulk_decode_logs", info=True) }}
+        {{ var("API_INTEGRATION") }} AS 'https://{{ var("EXTERNAL_FUNCTION_URI") | lower }}bulk_decode_logs'
+    {% elif  target.name == "sbx" %}
+        {{ log("Creating stg udf_bulk_decode_logs", info=True) }}
+        {{ var("API_INTEGRATION") }} AS 'https://{{ var("EXTERNAL_FUNCTION_URI") | lower }}bulk_decode_logs'
+    {% else %}
+        {{ log("Creating default (dev) udf_bulk_decode_logs", info=True) }}
+        {{ var("config")["dev"]["API_INTEGRATION"] }} AS 'https://{{ var("config")["dev"]["EXTERNAL_FUNCTION_URI"] | lower }}bulk_decode_logs'
+    {% endif %};
+    {% endset %}
+    {{ log(sql, info=True) }}
+    {% do adapter.execute(sql) %}
+{% endmacro %}
+
+{% macro create_udf_bulk_rest_api_v2_evm() %}    
+    {{ log("Creating udf udf_bulk_rest_api for target:" ~ target.name ~ ", schema: " ~ target.schema ~ ", DB: " ~ target.database, info=True) }}
+    {{ log("role:" ~ target.role ~ ", user:" ~ target.user, info=True) }}
+
+    {% set sql %}
+    CREATE OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_rest_api_v2(json object) returns array api_integration = 
+    {% if target.name == "prod" %} 
+        {{ log("Creating prod udf_bulk_rest_api_v2", info=True) }}
+        {{ var("API_INTEGRATION") }} AS 'https://{{ var("EXTERNAL_FUNCTION_URI") | lower }}udf_bulk_rest_api'
+    {% elif target.name == "dev" %}
+        {{ log("Creating dev udf_bulk_rest_api_v2", info=True) }}
+        {{ var("API_INTEGRATION") }} AS 'https://{{ var("EXTERNAL_FUNCTION_URI") | lower }}udf_bulk_rest_api'
+    {% elif  target.name == "sbx" %}
+        {{ log("Creating stg udf_bulk_rest_api_v2", info=True) }}
+        {{ var("API_INTEGRATION") }} AS 'https://{{ var("EXTERNAL_FUNCTION_URI") | lower }}udf_bulk_rest_api'
+    {% else %}
+        {{ log("Creating default (dev) udf_bulk_rest_api_v2", info=True) }}
+        {{ var("config")["dev"]["API_INTEGRATION"] }} AS 'https://{{ var("config")["dev"]["EXTERNAL_FUNCTION_URI"] | lower }}udf_bulk_rest_api'
+    {% endif %};
+    {% endset %}
+    {{ log(sql, info=True) }}
+    {% do adapter.execute(sql) %}
+{% endmacro %}