From 2ca39cd338609df46c0b74fa92651575e05e1d98 Mon Sep 17 00:00:00 2001 From: Gavin Aguiar Date: Fri, 22 Jul 2022 16:12:33 -0500 Subject: [PATCH] Binding name updates --- azure/functions/decorators/function_app.py | 212 ++++++++--------- docs/ProgModelSpec.pyi | 188 ++++++++-------- tests/decorators/test_decorators.py | 250 ++++++++++----------- 3 files changed, 325 insertions(+), 325 deletions(-) diff --git a/azure/functions/decorators/function_app.py b/azure/functions/decorators/function_app.py index cfe36ed3..a5839a19 100644 --- a/azure/functions/decorators/function_app.py +++ b/azure/functions/decorators/function_app.py @@ -923,17 +923,17 @@ def decorator(): class BindingApi(DecoratorApi, ABC): """Interface to extend for using existing binding decorator functions.""" - def write_service_bus_queue(self, - arg_name: str, - connection: str, - queue_name: str, - data_type: Optional[ - Union[DataType, str]] = None, - access_rights: Optional[Union[ - AccessRights, str]] = None, - **kwargs) -> \ + def service_bus_queue_output(self, + arg_name: str, + connection: str, + queue_name: str, + data_type: Optional[ + Union[DataType, str]] = None, + access_rights: Optional[Union[ + AccessRights, str]] = None, + **kwargs) -> \ Callable: - """The write_service_bus_queue decorator adds + """The service_bus_queue_output decorator adds :class:`ServiceBusQueueOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining ServiceBusQueueOutput @@ -974,18 +974,18 @@ def decorator(): return wrap - def write_service_bus_topic(self, - arg_name: str, - connection: str, - topic_name: str, - subscription_name: Optional[str] = None, - data_type: Optional[ - Union[DataType, str]] = None, - access_rights: Optional[Union[ - AccessRights, str]] = None, - **kwargs) -> \ + def service_bus_topic_output(self, + arg_name: str, + connection: str, + topic_name: str, + subscription_name: Optional[str] = None, + data_type: Optional[ + Union[DataType, str]] = None, + access_rights: Optional[Union[ + AccessRights, str]] = None, + **kwargs) -> \ Callable: - """The write_service_bus_topic decorator adds + """The service_bus_topic_output decorator adds :class:`ServiceBusTopicOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining ServiceBusTopicOutput @@ -1029,13 +1029,13 @@ def decorator(): return wrap - def write_queue(self, - arg_name: str, - queue_name: str, - connection: str, - data_type: Optional[DataType] = None, - **kwargs) -> Callable: - """The write_queue decorator adds :class:`QueueOutput` to the + def queue_output(self, + arg_name: str, + queue_name: str, + connection: str, + data_type: Optional[DataType] = None, + **kwargs) -> Callable: + """The queue_output decorator adds :class:`QueueOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining QueueOutput @@ -1075,15 +1075,15 @@ def decorator(): return wrap - def write_event_hub_message(self, - arg_name: str, - connection: str, - event_hub_name: str, - data_type: Optional[ - Union[DataType, str]] = None, - **kwargs) -> \ + def event_hub_output(self, + arg_name: str, + connection: str, + event_hub_name: str, + data_type: Optional[ + Union[DataType, str]] = None, + **kwargs) -> \ Callable: - """The write_event_hub_message decorator adds + """The event_hub_output decorator adds :class:`EventHubOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining EventHubOutput @@ -1124,22 +1124,22 @@ def decorator(): return wrap - def write_cosmos_db_documents(self, - arg_name: str, - database_name: str, - collection_name: str, - connection_string_setting: str, - create_if_not_exists: Optional[bool] = None, - partition_key: Optional[str] = None, - collection_throughput: Optional[int] = None, - use_multiple_write_locations: Optional[ - bool] = None, - preferred_locations: Optional[str] = None, - data_type: Optional[ - Union[DataType, str]] = None, - **kwargs) \ + def cosmos_db_output(self, + arg_name: str, + database_name: str, + collection_name: str, + connection_string_setting: str, + create_if_not_exists: Optional[bool] = None, + partition_key: Optional[str] = None, + collection_throughput: Optional[int] = None, + use_multiple_write_locations: Optional[ + bool] = None, + preferred_locations: Optional[str] = None, + data_type: Optional[ + Union[DataType, str]] = None, + **kwargs) \ -> Callable: - """The write_cosmos_db_documents decorator adds + """The cosmos_db_output decorator adds :class:`CosmosDBOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining CosmosDBOutput @@ -1199,19 +1199,19 @@ def decorator(): return wrap - def read_cosmos_db_documents(self, - arg_name: str, - database_name: str, - collection_name: str, - connection_string_setting: str, - id: Optional[str] = None, - sql_query: Optional[str] = None, - partition_key: Optional[str] = None, - data_type: Optional[ - Union[DataType, str]] = None, - **kwargs) \ + def cosmos_db_input(self, + arg_name: str, + database_name: str, + collection_name: str, + connection_string_setting: str, + id: Optional[str] = None, + sql_query: Optional[str] = None, + partition_key: Optional[str] = None, + data_type: Optional[ + Union[DataType, str]] = None, + **kwargs) \ -> Callable: - """The read_cosmos_db_documents decorator adds + """The cosmos_db_input decorator adds :class:`CosmosDBInput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining CosmosDBInput @@ -1262,14 +1262,14 @@ def decorator(): return wrap - def read_blob(self, - arg_name: str, - path: str, - connection: str, - data_type: Optional[DataType] = None, - **kwargs) -> Callable: + def blob_input(self, + arg_name: str, + path: str, + connection: str, + data_type: Optional[DataType] = None, + **kwargs) -> Callable: """ - The read_blob decorator adds :class:`BlobInput` to the + The blob_input decorator adds :class:`BlobInput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining BlobInput @@ -1310,14 +1310,14 @@ def decorator(): return wrap - def write_blob(self, - arg_name: str, - path: str, - connection: str, - data_type: Optional[DataType] = None, - **kwargs) -> Callable: + def blob_output(self, + arg_name: str, + path: str, + connection: str, + data_type: Optional[DataType] = None, + **kwargs) -> Callable: """ - The write_blob decorator adds :class:`BlobOutput` to the + The blob_output decorator adds :class:`BlobOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining BlobOutput @@ -1357,15 +1357,15 @@ def decorator(): return wrap - def write_event_grid(self, - arg_name: str, - topic_endpoint_uri: str, - topic_key_setting: str, - data_type: Optional[ - Union[DataType, str]] = None, - **kwargs) -> Callable: + def event_grid_output(self, + arg_name: str, + topic_endpoint_uri: str, + topic_key_setting: str, + data_type: Optional[ + Union[DataType, str]] = None, + **kwargs) -> Callable: """ - The write_event_grid decorator adds + The event_grid_output decorator adds :class:`EventGridOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function @@ -1405,18 +1405,18 @@ def decorator(): return wrap - def read_table(self, - arg_name: str, - connection: str, - table_name: str, - row_key: Optional[str] = None, - partition_key: Optional[str] = None, - take: Optional[int] = None, - filter: Optional[str] = None, - data_type: Optional[ - Union[DataType, str]] = None) -> Callable: + def table_input(self, + arg_name: str, + connection: str, + table_name: str, + row_key: Optional[str] = None, + partition_key: Optional[str] = None, + take: Optional[int] = None, + filter: Optional[str] = None, + data_type: Optional[ + Union[DataType, str]] = None) -> Callable: """ - The read_table decorator adds :class:`TableInput` to the + The table_input decorator adds :class:`TableInput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining TableInput @@ -1441,6 +1441,7 @@ def read_table(self, parameter value. :return: Decorator function. """ + @self._configure_function_builder def wrap(fb): def decorator(): @@ -1461,17 +1462,16 @@ def decorator(): return wrap - def write_table(self, - arg_name: str, - connection: str, - table_name: str, - row_key: Optional[str] = None, - partition_key: Optional[str] = None, - data_type: Optional[ - Union[DataType, str]] = None) -> Callable: - + def table_output(self, + arg_name: str, + connection: str, + table_name: str, + row_key: Optional[str] = None, + partition_key: Optional[str] = None, + data_type: Optional[ + Union[DataType, str]] = None) -> Callable: """ - The write_table decorator adds :class:`TableOutput` to the + The table_output decorator adds :class:`TableOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining TableOutput diff --git a/docs/ProgModelSpec.pyi b/docs/ProgModelSpec.pyi index 1da7caca..ed3aeea0 100644 --- a/docs/ProgModelSpec.pyi +++ b/docs/ProgModelSpec.pyi @@ -596,17 +596,17 @@ class TriggerApi(DecoratorApi, ABC): class BindingApi(DecoratorApi, ABC): """Interface to extend for using existing binding decorator functions.""" - def write_service_bus_queue(self, - arg_name: str, - connection: str, - queue_name: str, - data_type: Optional[ + def service_bus_queue_output(self, + arg_name: str, + connection: str, + queue_name: str, + data_type: Optional[ Union[DataType, str]] = None, - access_rights: Optional[Union[ + access_rights: Optional[Union[ AccessRights, str]] = None, - **kwargs) -> \ + **kwargs) -> \ Callable: - """The write_service_bus_queue decorator adds + """The service_bus_queue_output decorator adds :class:`ServiceBusQueueOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining ServiceBusQueueOutput @@ -630,18 +630,18 @@ class BindingApi(DecoratorApi, ABC): pass - def write_service_bus_topic(self, - arg_name: str, - connection: str, - topic_name: str, - subscription_name: Optional[str] = None, - data_type: Optional[ + def service_bus_topic_output(self, + arg_name: str, + connection: str, + topic_name: str, + subscription_name: Optional[str] = None, + data_type: Optional[ Union[DataType, str]] = None, - access_rights: Optional[Union[ + access_rights: Optional[Union[ AccessRights, str]] = None, - **kwargs) -> \ + **kwargs) -> \ Callable: - """The write_service_bus_topic decorator adds + """The service_bus_topic_output decorator adds :class:`ServiceBusTopicOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining ServiceBusTopicOutput @@ -666,13 +666,13 @@ class BindingApi(DecoratorApi, ABC): pass - def write_queue(self, - arg_name: str, - queue_name: str, - connection: str, - data_type: Optional[DataType] = None, - **kwargs) -> Callable: - """The write_queue decorator adds :class:`QueueOutput` to the + def queue_output(self, + arg_name: str, + queue_name: str, + connection: str, + data_type: Optional[DataType] = None, + **kwargs) -> Callable: + """The queue_output decorator adds :class:`QueueOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining QueueOutput @@ -698,15 +698,15 @@ class BindingApi(DecoratorApi, ABC): pass - def write_event_hub_message(self, - arg_name: str, - connection: str, - event_hub_name: str, - data_type: Optional[ + def event_hub_output(self, + arg_name: str, + connection: str, + event_hub_name: str, + data_type: Optional[ Union[DataType, str]] = None, - **kwargs) -> \ + **kwargs) -> \ Callable: - """The write_event_hub_message decorator adds + """The event_hub_output decorator adds :class:`EventHubOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining EventHubOutput @@ -732,22 +732,22 @@ class BindingApi(DecoratorApi, ABC): pass - def write_cosmos_db_documents(self, - arg_name: str, - database_name: str, - collection_name: str, - connection_string_setting: str, - create_if_not_exists: Optional[bool] = None, - partition_key: Optional[str] = None, - collection_throughput: Optional[int] = None, - use_multiple_write_locations: Optional[ + def cosmos_db_output(self, + arg_name: str, + database_name: str, + collection_name: str, + connection_string_setting: str, + create_if_not_exists: Optional[bool] = None, + partition_key: Optional[str] = None, + collection_throughput: Optional[int] = None, + use_multiple_write_locations: Optional[ bool] = None, - preferred_locations: Optional[str] = None, - data_type: Optional[ + preferred_locations: Optional[str] = None, + data_type: Optional[ Union[DataType, str]] = None, - **kwargs) \ + **kwargs) \ -> Callable: - """The write_cosmos_db_documents decorator adds + """The cosmos_db_output decorator adds :class:`CosmosDBOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining CosmosDBOutput @@ -786,19 +786,19 @@ class BindingApi(DecoratorApi, ABC): pass - def read_cosmos_db_documents(self, - arg_name: str, - database_name: str, - collection_name: str, - connection_string_setting: str, - id: Optional[str] = None, - sql_query: Optional[str] = None, - partition_key: Optional[str] = None, - data_type: Optional[ + def cosmos_db_input(self, + arg_name: str, + database_name: str, + collection_name: str, + connection_string_setting: str, + id: Optional[str] = None, + sql_query: Optional[str] = None, + partition_key: Optional[str] = None, + data_type: Optional[ Union[DataType, str]] = None, - **kwargs) \ + **kwargs) \ -> Callable: - """The read_cosmos_db_documents decorator adds + """The cosmos_db_input decorator adds :class:`CosmosDBInput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining CosmosDBInput @@ -830,14 +830,14 @@ class BindingApi(DecoratorApi, ABC): pass - def read_blob(self, - arg_name: str, - path: str, - connection: str, - data_type: Optional[DataType] = None, - **kwargs) -> Callable: + def blob_input(self, + arg_name: str, + path: str, + connection: str, + data_type: Optional[DataType] = None, + **kwargs) -> Callable: """ - The read_blob decorator adds :class:`BlobInput` to the + The blob_input decorator adds :class:`BlobInput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining BlobInput @@ -863,14 +863,14 @@ class BindingApi(DecoratorApi, ABC): pass - def write_blob(self, - arg_name: str, - path: str, - connection: str, - data_type: Optional[DataType] = None, - **kwargs) -> Callable: + def blob_output(self, + arg_name: str, + path: str, + connection: str, + data_type: Optional[DataType] = None, + **kwargs) -> Callable: """ - The write_blob decorator adds :class:`BlobOutput` to the + The blob_output decorator adds :class:`BlobOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining BlobOutput @@ -895,15 +895,15 @@ class BindingApi(DecoratorApi, ABC): pass - def write_event_grid(self, - arg_name: str, - topic_endpoint_uri: str, - topic_key_setting: str, - data_type: Optional[ + def event_grid_output(self, + arg_name: str, + topic_endpoint_uri: str, + topic_key_setting: str, + data_type: Optional[ Union[DataType, str]] = None, - **kwargs) -> Callable: + **kwargs) -> Callable: """ - The write_event_grid decorator adds + The event_grid_output decorator adds :class:`EventGridOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function @@ -928,18 +928,18 @@ class BindingApi(DecoratorApi, ABC): pass - def read_table(self, - arg_name: str, - connection: str, - table_name: str, - row_key: Optional[str] = None, - partition_key: Optional[str] = None, - take: Optional[int] = None, - filter: Optional[str] = None, - data_type: Optional[ + def table_input(self, + arg_name: str, + connection: str, + table_name: str, + row_key: Optional[str] = None, + partition_key: Optional[str] = None, + take: Optional[int] = None, + filter: Optional[str] = None, + data_type: Optional[ Union[DataType, str]] = None) -> Callable: """ - The read_table decorator adds :class:`TableInput` to the + The table_input decorator adds :class:`TableInput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining TableInput @@ -967,17 +967,17 @@ class BindingApi(DecoratorApi, ABC): pass - def write_table(self, - arg_name: str, - connection: str, - table_name: str, - row_key: str, - partition_key: str, - data_type: Optional[ + def table_output(self, + arg_name: str, + connection: str, + table_name: str, + row_key: str, + partition_key: str, + data_type: Optional[ Union[DataType, str]] = None) -> Callable: """ - The write_table decorator adds :class:`TableOutput` to the + The table_output decorator adds :class:`TableOutput` to the :class:`FunctionBuilder` object for building :class:`Function` object used in worker function indexing model. This is equivalent to defining TableOutput diff --git a/tests/decorators/test_decorators.py b/tests/decorators/test_decorators.py index be610455..edbf2340 100644 --- a/tests/decorators/test_decorators.py +++ b/tests/decorators/test_decorators.py @@ -178,8 +178,8 @@ def test_queue_default_args(self): @app.queue_trigger(arg_name="req", queue_name="dummy_queue", connection="dummy_conn") - @app.write_queue(arg_name="out", queue_name="dummy_out_queue", - connection="dummy_out_conn") + @app.queue_output(arg_name="out", queue_name="dummy_out_queue", + connection="dummy_out_conn") def dummy(): pass @@ -228,8 +228,8 @@ def test_queue_output_binding(self): @app.queue_trigger(arg_name="req", queue_name="dummy_queue", connection="dummy_conn") - @app.write_queue(arg_name="out", queue_name="dummy_out_queue", - connection="dummy_out_conn") + @app.queue_output(arg_name="out", queue_name="dummy_out_queue", + connection="dummy_out_conn") def dummy(): pass @@ -252,9 +252,9 @@ def test_queue_full_args(self): @app.queue_trigger(arg_name="req", queue_name="dummy_queue", connection="dummy_conn", data_type=DataType.STRING, dummy_field="dummy") - @app.write_queue(arg_name="out", queue_name="dummy_out_queue", - connection="dummy_out_conn", - data_type=DataType.STRING, dummy_field="dummy") + @app.queue_output(arg_name="out", queue_name="dummy_out_queue", + connection="dummy_out_conn", + data_type=DataType.STRING, dummy_field="dummy") def dummy(): pass @@ -287,9 +287,9 @@ def test_service_bus_queue_default_args(self): @app.service_bus_queue_trigger(arg_name="req", connection="dummy_conn", queue_name="dummy_queue") - @app.write_service_bus_queue(arg_name='res', - connection='dummy_out_conn', - queue_name='dummy_out_queue') + @app.service_bus_queue_output(arg_name='res', + connection='dummy_out_conn', + queue_name='dummy_out_queue') def dummy(): pass @@ -342,9 +342,9 @@ def test_service_bus_queue_output_binding(self): @app.service_bus_queue_trigger(arg_name="req", connection="dummy_conn", queue_name="dummy_queue") - @app.write_service_bus_queue(arg_name='res', - connection='dummy_out_conn', - queue_name='dummy_out_queue') + @app.service_bus_queue_output(arg_name='res', + connection='dummy_out_conn', + queue_name='dummy_out_queue') def dummy(): pass @@ -372,12 +372,12 @@ def test_service_bus_queue_full_args(self): is_sessions_enabled=True, cardinality=Cardinality.MANY, dummy_field="dummy") - @app.write_service_bus_queue(arg_name='res', - connection='dummy_out_conn', - queue_name='dummy_out_queue', - data_type=DataType.STREAM, - access_rights=AccessRights.MANAGE, - dummy_field="dummy") + @app.service_bus_queue_output(arg_name='res', + connection='dummy_out_conn', + queue_name='dummy_out_queue', + data_type=DataType.STREAM, + access_rights=AccessRights.MANAGE, + dummy_field="dummy") def dummy(): pass @@ -417,9 +417,9 @@ def test_service_bus_topic_default_args(self): connection='dummy_conn', topic_name='dummy_topic', subscription_name='dummy_sub') - @app.write_service_bus_topic(arg_name='res', connection='dummy_conn', - topic_name='dummy_topic', - subscription_name='dummy_sub') + @app.service_bus_topic_output(arg_name='res', connection='dummy_conn', + topic_name='dummy_topic', + subscription_name='dummy_sub') def dummy(): pass @@ -477,9 +477,9 @@ def test_service_bus_topic_output_binding(self): connection='dummy_conn', topic_name='dummy_topic', subscription_name='dummy_sub') - @app.write_service_bus_topic(arg_name='res', connection='dummy_conn', - topic_name='dummy_topic', - subscription_name='dummy_sub') + @app.service_bus_topic_output(arg_name='res', connection='dummy_conn', + topic_name='dummy_topic', + subscription_name='dummy_sub') def dummy(): pass @@ -509,12 +509,12 @@ def test_service_bus_topic_full_args(self): is_sessions_enabled=False, cardinality=Cardinality.MANY, dummy_field="dummy") - @app.write_service_bus_topic(arg_name='res', connection='dummy_conn', - topic_name='dummy_topic', - subscription_name='dummy_sub', - data_type=DataType.STRING, - access_rights=AccessRights.LISTEN, - dummy_field="dummy") + @app.service_bus_topic_output(arg_name='res', connection='dummy_conn', + topic_name='dummy_topic', + subscription_name='dummy_sub', + data_type=DataType.STRING, + access_rights=AccessRights.LISTEN, + dummy_field="dummy") def dummy(): pass @@ -555,9 +555,9 @@ def test_event_hub_default_args(self): @app.event_hub_message_trigger(arg_name="req", connection="dummy_connection", event_hub_name="dummy_event_hub") - @app.write_event_hub_message(arg_name="res", - event_hub_name="dummy_event_hub", - connection="dummy_connection") + @app.event_hub_output(arg_name="res", + event_hub_name="dummy_event_hub", + connection="dummy_connection") def dummy(): pass @@ -610,9 +610,9 @@ def test_event_hub_output_binding(self): @app.event_hub_message_trigger(arg_name="req", connection="dummy_connection", event_hub_name="dummy_event_hub") - @app.write_event_hub_message(arg_name="res", - event_hub_name="dummy_event_hub", - connection="dummy_connection") + @app.event_hub_output(arg_name="res", + event_hub_name="dummy_event_hub", + connection="dummy_connection") def dummy(): pass @@ -639,11 +639,11 @@ def test_event_hub_full_args(self): consumer_group="dummy_group", data_type=DataType.UNDEFINED, dummy_field="dummy") - @app.write_event_hub_message(arg_name="res", - event_hub_name="dummy_event_hub", - connection="dummy_connection", - data_type=DataType.UNDEFINED, - dummy_field="dummy") + @app.event_hub_output(arg_name="res", + event_hub_name="dummy_event_hub", + connection="dummy_connection", + data_type=DataType.UNDEFINED, + dummy_field="dummy") def dummy(): pass @@ -700,26 +700,26 @@ def test_cosmosdb_full_args(self): preferred_locations="dummy_loc", data_type=DataType.STRING, dummy_field="dummy") - @app.read_cosmos_db_documents(arg_name="in", - database_name="dummy_in_db", - collection_name="dummy_in_collection", - connection_string_setting="dummy_str", - id="dummy_id", - sql_query="dummy_query", - partition_key="dummy_partitions", - data_type=DataType.STRING, - dummy_field="dummy") - @app.write_cosmos_db_documents(arg_name="out", - database_name="dummy_out_db", - collection_name="dummy_out_collection", - connection_string_setting="dummy_str", - create_if_not_exists=False, - partition_key="dummy_part_key", - collection_throughput=1, - use_multiple_write_locations=False, - preferred_locations="dummy_location", - data_type=DataType.STRING, - dummy_field="dummy") + @app.cosmos_db_input(arg_name="in", + database_name="dummy_in_db", + collection_name="dummy_in_collection", + connection_string_setting="dummy_str", + id="dummy_id", + sql_query="dummy_query", + partition_key="dummy_partitions", + data_type=DataType.STRING, + dummy_field="dummy") + @app.cosmos_db_output(arg_name="out", + database_name="dummy_out_db", + collection_name="dummy_out_collection", + connection_string_setting="dummy_str", + create_if_not_exists=False, + partition_key="dummy_part_key", + collection_throughput=1, + use_multiple_write_locations=False, + preferred_locations="dummy_location", + data_type=DataType.STRING, + dummy_field="dummy") def dummy(): pass @@ -799,14 +799,14 @@ def test_cosmosdb_default_args(self): @app.cosmos_db_trigger(arg_name="trigger", database_name="dummy_db", collection_name="dummy_collection", connection_string_setting="dummy_str") - @app.read_cosmos_db_documents(arg_name="in", - database_name="dummy_in_db", - collection_name="dummy_in_collection", - connection_string_setting="dummy_str") - @app.write_cosmos_db_documents(arg_name="out", - database_name="dummy_out_db", - collection_name="dummy_out_collection", - connection_string_setting="dummy_str") + @app.cosmos_db_input(arg_name="in", + database_name="dummy_in_db", + collection_name="dummy_in_collection", + connection_string_setting="dummy_str") + @app.cosmos_db_output(arg_name="out", + database_name="dummy_out_db", + collection_name="dummy_out_collection", + connection_string_setting="dummy_str") def dummy(): pass @@ -874,10 +874,10 @@ def test_cosmosdb_input_binding(self): database_name="dummy_db", collection_name="dummy_collection", connection_string_setting="dummy_str") - @app.read_cosmos_db_documents(arg_name="in", - database_name="dummy_in_db", - collection_name="dummy_in_collection", - connection_string_setting="dummy_str") + @app.cosmos_db_input(arg_name="in", + database_name="dummy_in_db", + collection_name="dummy_in_collection", + connection_string_setting="dummy_str") def dummy(): pass @@ -903,10 +903,10 @@ def test_cosmosdb_output_binding(self): database_name="dummy_db", collection_name="dummy_collection", connection_string_setting="dummy_str") - @app.write_cosmos_db_documents(arg_name="out", - database_name="dummy_out_db", - collection_name="dummy_out_collection", - connection_string_setting="dummy_str") + @app.cosmos_db_output(arg_name="out", + database_name="dummy_out_db", + collection_name="dummy_out_collection", + connection_string_setting="dummy_str") def dummy(): pass @@ -946,8 +946,8 @@ def dummy(): def test_no_trigger(self): app = self.func_app with self.assertRaises(ValueError) as err: - @app.write_queue(arg_name="out", queue_name="dummy_out_queue", - connection="dummy_out_conn") + @app.queue_output(arg_name="out", queue_name="dummy_out_queue", + connection="dummy_out_conn") def dummy(): pass @@ -962,7 +962,7 @@ def test_multiple_input_bindings(self): app = self.func_app @app.schedule(arg_name="req1", schedule="dummy_schedule") - @app.read_cosmos_db_documents( + @app.cosmos_db_input( arg_name="in1", database_name="dummy_in_db", collection_name="dummy_in_collection", @@ -971,7 +971,7 @@ def test_multiple_input_bindings(self): sql_query="dummy_query", partition_key="dummy_partitions", data_type=DataType.STRING) - @app.read_cosmos_db_documents( + @app.cosmos_db_input( arg_name="in2", database_name="dummy_in_db", collection_name="dummy_in_collection", @@ -980,9 +980,9 @@ def test_multiple_input_bindings(self): sql_query="dummy_query", partition_key="dummy_partitions", data_type=DataType.STRING) - @app.write_queue(arg_name="out1", queue_name="dummy_out_queue", - connection="dummy_out_conn") - @app.write_event_hub_message( + @app.queue_output(arg_name="out1", queue_name="dummy_out_queue", + connection="dummy_out_conn") + @app.event_hub_output( arg_name="res", event_hub_name="dummy_event_hub", connection="dummy_connection") @@ -1109,10 +1109,10 @@ def test_blob_default_args(self): @app.blob_trigger(arg_name="req", path="dummy_path", connection="dummy_conn") - @app.read_blob(arg_name="file", path="dummy_path", - connection="dummy_conn") - @app.write_blob(arg_name="out", path="dummy_out_path", - connection="dummy_out_conn") + @app.blob_input(arg_name="file", path="dummy_path", + connection="dummy_conn") + @app.blob_output(arg_name="out", path="dummy_out_path", + connection="dummy_out_conn") def dummy(): pass @@ -1172,9 +1172,9 @@ def test_blob_input_binding(self): @app.blob_trigger(arg_name="req", path="dummy_path", data_type=DataType.STRING, connection="dummy_conn") - @app.read_blob(arg_name="file", path="dummy_in_path", - connection="dummy_in_conn", - data_type=DataType.STRING) + @app.blob_input(arg_name="file", path="dummy_in_path", + connection="dummy_in_conn", + data_type=DataType.STRING) def dummy(): pass @@ -1210,9 +1210,9 @@ def test_blob_output_binding(self): @app.blob_trigger(arg_name="req", path="dummy_path", data_type=DataType.STRING, connection="dummy_conn") - @app.write_blob(arg_name="out", path="dummy_out_path", - connection="dummy_out_conn", - data_type=DataType.STRING) + @app.blob_output(arg_name="out", path="dummy_out_path", + connection="dummy_out_conn", + data_type=DataType.STRING) def dummy(): pass @@ -1417,7 +1417,7 @@ def test_event_grid_default_args(self): app = self.func_app @app.event_grid_trigger(arg_name="req") - @app.write_event_grid( + @app.event_grid_output( arg_name="res", topic_endpoint_uri="dummy_topic_endpoint_uri", topic_key_setting="dummy_topic_key_setting") @@ -1450,7 +1450,7 @@ def test_event_grid_full_args(self): @app.event_grid_trigger(arg_name="req", data_type=DataType.UNDEFINED, dummy_field="dummy") - @app.write_event_grid( + @app.event_grid_output( arg_name="res", topic_endpoint_uri="dummy_topic_endpoint_uri", topic_key_setting="dummy_topic_key_setting", @@ -1506,7 +1506,7 @@ def test_event_grid_output_binding(self): app = self.func_app @app.event_grid_trigger(arg_name="req") - @app.write_event_grid( + @app.event_grid_output( arg_name="res", topic_endpoint_uri="dummy_topic_endpoint_uri", topic_key_setting="dummy_topic_key_setting") @@ -1530,12 +1530,12 @@ def test_table_default_args(self): app = self.func_app @app.route() - @app.read_table(arg_name="in", table_name="dummy_table_name", - connection="dummy_in_conn") - @app.write_table(arg_name="out", table_name="dummy_table_name", - connection="dummy_out_conn", - row_key="dummy_key", - partition_key="dummy_partition_key") + @app.table_input(arg_name="in", table_name="dummy_table_name", + connection="dummy_in_conn") + @app.table_output(arg_name="out", table_name="dummy_table_name", + connection="dummy_out_conn", + row_key="dummy_key", + partition_key="dummy_partition_key") def dummy(): pass @@ -1583,16 +1583,16 @@ def test_table_with_all_args(self): auth_level=AuthLevel.FUNCTION, route='dummy_route', trigger_extra_fields={"dummy_field": "dummy"}, binding_extra_fields={"dummy_field": "dummy"}) - @app.read_table(arg_name="in", table_name="dummy_table_name", - connection="dummy_in_conn", - row_key="dummy_key", - partition_key="dummy_partition_key", - take=1, - filter="dummy_filter") - @app.write_table(arg_name="out", table_name="dummy_table_name", - connection="dummy_out_conn", + @app.table_input(arg_name="in", table_name="dummy_table_name", + connection="dummy_in_conn", row_key="dummy_key", - partition_key="dummy_partition_key") + partition_key="dummy_partition_key", + take=1, + filter="dummy_filter") + @app.table_output(arg_name="out", table_name="dummy_table_name", + connection="dummy_out_conn", + row_key="dummy_key", + partition_key="dummy_partition_key") def dummy(): pass @@ -1644,13 +1644,13 @@ def test_table_input_binding(self): app = self.func_app @app.route() - @app.read_table(arg_name="in", table_name="dummy_table_name", - connection="dummy_in_conn", - row_key="dummy_key", - partition_key="dummy_partition_key", - take=1, - filter="dummy_filter", - data_type=DataType.STRING) + @app.table_input(arg_name="in", table_name="dummy_table_name", + connection="dummy_in_conn", + row_key="dummy_key", + partition_key="dummy_partition_key", + take=1, + filter="dummy_filter", + data_type=DataType.STRING) def dummy(): pass @@ -1677,11 +1677,11 @@ def test_table_output_binding(self): app = self.func_app @app.route() - @app.write_table(arg_name="out", table_name="dummy_table_name", - connection="dummy_out_conn", - row_key="dummy_key", - partition_key="dummy_partition_key", - data_type=DataType.STRING) + @app.table_output(arg_name="out", table_name="dummy_table_name", + connection="dummy_out_conn", + row_key="dummy_key", + partition_key="dummy_partition_key", + data_type=DataType.STRING) def dummy(): pass