diff --git a/macros/streamline/api_integrations.sql b/macros/streamline/api_integrations.sql
index 5022425..8faa3ea 100644
--- a/macros/streamline/api_integrations.sql
+++ b/macros/streamline/api_integrations.sql
@@ -12,9 +12,17 @@
         CREATE api integration IF NOT EXISTS aws_flow_api_prod_us_east_2 api_provider = aws_api_gateway api_aws_role_arn = 'arn:aws:iam::490041342817:role/flow-api-prod-rolesnowflakeudfsAF733095-F6SPYWFGQX9Z' api_allowed_prefixes = (
             'https://78rpbojpue.execute-api.us-east-2.amazonaws.com/prod/'
         ) enabled = TRUE;
+    
         {% endset %}
         {% do run_query(sql) %}
         
+        {% set sql %}
+        CREATE api integration IF NOT EXISTS aws_flow_evm_api_prod api_provider = aws_api_gateway api_aws_role_arn = 'arn:aws:iam::924682671219:role/flow-api-prod-rolesnowflakeudfsAF733095-RmrgKIWbzoFL' api_allowed_prefixes = (
+            'https://rajpkbgko9.execute-api.us-east-1.amazonaws.com/prod/'
+        ) enabled = TRUE;
+    
+        {% endset %}
+        {% do run_query(sql) %}
     {% elif target.name == "dev" %}
         {{ log("Generating api integration for target:" ~ target.name, info=True) }}
         {% set sql %}
@@ -30,6 +38,13 @@
         ) enabled = TRUE;
         {% endset %}
         {% do run_query(sql) %}
+
+        {% set sql %}
+        CREATE api integration IF NOT EXISTS aws_flow_evm_api_dev api_provider = aws_api_gateway api_aws_role_arn = 'arn:aws:iam::704693948482:role/flow-api-stg-rolesnowflakeudfsAF733095-tPEdygwPC6IV' api_allowed_prefixes = (
+            'https://pfv9lhg3kg.execute-api.us-east-1.amazonaws.com/stg/'
+        ) enabled = TRUE;
+        {% endset %}
+        {% do run_query(sql) %}
     {% elif target.name == "sbx" %}
         {{ log("Generating api integration for target:" ~ target.name, info=True) }}
         {% set sql %}
diff --git a/macros/streamline/streamline_udfs.sql b/macros/streamline/streamline_udfs.sql
index 84d77ae..e149c77 100644
--- a/macros/streamline/streamline_udfs.sql
+++ b/macros/streamline/streamline_udfs.sql
@@ -65,3 +65,25 @@
     {%- endif %};
 {% endmacro %}
 
+{% macro create_udf_bulk_rest_api_v2() %}
+    CREATE
+    OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_rest_api_v2(
+        json OBJECT
+    ) returns ARRAY api_integration = 
+    {% if target.name == "prod" %}
+        aws_flow_evm_api_prod AS 'https://rajpkbgko9.execute-api.us-east-1.amazonaws.com/prod/udf_bulk_rest_api'
+    {% else %}
+        aws_flow_evm_api_dev AS 'https://pfv9lhg3kg.execute-api.us-east-1.amazonaws.com/stg/udf_bulk_rest_api'
+    {%- endif %};
+{% endmacro %}
+
+{% macro create_udf_bulk_decode_logs() %}
+    CREATE
+    OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_decode_logs(
+        json OBJECT
+    ) returns ARRAY api_integration = {% if target.name == "prod" %}
+        aws_flow_evm_api_prod AS 'https://rajpkbgko9.execute-api.us-east-1.amazonaws.com/prod/bulk_decode_logs'
+    {% else %}
+        aws_flow_evm_api_dev AS'https://pfv9lhg3kg.execute-api.us-east-1.amazonaws.com/stg/bulk_decode_logs'
+    {%- endif %};
+{% endmacro %}
\ No newline at end of file