From 0720287a42561cabb9748c4c7a6324b3b27e9af0 Mon Sep 17 00:00:00 2001 From: Swathi Pillalamarri Date: Thu, 28 Oct 2021 19:56:08 -0700 Subject: [PATCH 1/5] move kwarg --- .../azure/schemaregistry/_schema_registry_client.py | 6 ++++-- .../schemaregistry/aio/_schema_registry_client_async.py | 6 ++++-- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_schema_registry_client.py b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_schema_registry_client.py index 7f41db19957f..b022e1567c15 100644 --- a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_schema_registry_client.py +++ b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_schema_registry_client.py @@ -114,6 +114,7 @@ def register_schema( except AttributeError: pass + logging_enable = kwargs.pop("logging_enable", False) request = schema_rest.build_register_request( group_name=group_name, schema_name=name, @@ -123,7 +124,7 @@ def register_schema( **kwargs ) - response = self._generated_client.send_request(request) + response = self._generated_client.send_request(request, logging_enable=logging_enable) response.raise_for_status() return _parse_response_schema_properties(response) @@ -181,6 +182,7 @@ def get_schema_properties( except AttributeError: pass + logging_enable = kwargs.pop("logging_enable", False) request = schema_rest.build_query_id_by_content_request( group_name=group_name, schema_name=name, @@ -190,6 +192,6 @@ def get_schema_properties( **kwargs ) - response = self._generated_client.send_request(request, **kwargs) + response = self._generated_client.send_request(request, logging_enable=logging_enable, **kwargs) response.raise_for_status() return _parse_response_schema_properties(response) diff --git a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/aio/_schema_registry_client_async.py b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/aio/_schema_registry_client_async.py index 242284a4cd6e..ef21381d823e 100644 --- a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/aio/_schema_registry_client_async.py +++ b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/aio/_schema_registry_client_async.py @@ -116,6 +116,7 @@ async def register_schema( except AttributeError: pass + logging_enable = kwargs.pop("logging_enable", False) request = schema_rest.build_register_request( group_name=group_name, schema_name=name, @@ -125,7 +126,7 @@ async def register_schema( **kwargs ) - response = await self._generated_client.send_request(request) + response = await self._generated_client.send_request(request, logging_enable=logging_enable) response.raise_for_status() return _parse_response_schema_properties(response) @@ -190,6 +191,7 @@ async def get_schema_properties( except AttributeError: pass + logging_enable = kwargs.pop("logging_enable", False) request = schema_rest.build_query_id_by_content_request( group_name=group_name, schema_name=name, @@ -199,6 +201,6 @@ async def get_schema_properties( **kwargs ) - response = await self._generated_client.send_request(request, **kwargs) + response = await self._generated_client.send_request(request, logging_enable=logging_enable, **kwargs) response.raise_for_status() return _parse_response_schema_properties(response) From fb773506aef7e9cc8cb9b2be43a1e0760559244f Mon Sep 17 00:00:00 2001 From: Swathi Pillalamarri Date: Fri, 29 Oct 2021 15:35:29 -0700 Subject: [PATCH 2/5] adams comments --- .../schemaregistry/_schema_registry_client.py | 18 +++++++++++------- .../aio/_schema_registry_client_async.py | 18 +++++++++++------- 2 files changed, 22 insertions(+), 14 deletions(-) diff --git a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_schema_registry_client.py b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_schema_registry_client.py index b022e1567c15..caf99637f312 100644 --- a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_schema_registry_client.py +++ b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_schema_registry_client.py @@ -114,17 +114,18 @@ def register_schema( except AttributeError: pass - logging_enable = kwargs.pop("logging_enable", False) + http_request_keywords = ["params", "headers", "json", "data", "files"] + http_request_kwargs = {key: kwargs.pop(key, None) for key in http_request_keywords if key in kwargs} request = schema_rest.build_register_request( group_name=group_name, schema_name=name, content=schema_definition, serialization_type=format, content_type=kwargs.pop("content_type", "application/json"), - **kwargs + **http_request_kwargs ) - response = self._generated_client.send_request(request, logging_enable=logging_enable) + response = self._generated_client.send_request(request, **kwargs) response.raise_for_status() return _parse_response_schema_properties(response) @@ -147,7 +148,9 @@ def get_schema(self, id, **kwargs): # pylint:disable=redefined-builtin :caption: Get schema by id. """ - request = schema_rest.build_get_by_id_request(schema_id=id) + http_request_keywords = ["params", "headers", "json", "data", "files"] + http_request_kwargs = {key: kwargs.pop(key, None) for key in http_request_keywords if key in kwargs} + request = schema_rest.build_get_by_id_request(schema_id=id, **http_request_kwargs) response = self._generated_client.send_request(request, **kwargs) response.raise_for_status() return _parse_response_schema(response) @@ -182,16 +185,17 @@ def get_schema_properties( except AttributeError: pass - logging_enable = kwargs.pop("logging_enable", False) + http_request_keywords = ["params", "headers", "json", "data", "files"] + http_request_kwargs = {key: kwargs.pop(key, None) for key in http_request_keywords if key in kwargs} request = schema_rest.build_query_id_by_content_request( group_name=group_name, schema_name=name, content=schema_definition, serialization_type=format, content_type=kwargs.pop("content_type", "application/json"), - **kwargs + **http_request_kwargs ) - response = self._generated_client.send_request(request, logging_enable=logging_enable, **kwargs) + response = self._generated_client.send_request(request, **kwargs) response.raise_for_status() return _parse_response_schema_properties(response) diff --git a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/aio/_schema_registry_client_async.py b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/aio/_schema_registry_client_async.py index ef21381d823e..a1508a89c4e3 100644 --- a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/aio/_schema_registry_client_async.py +++ b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/aio/_schema_registry_client_async.py @@ -116,17 +116,18 @@ async def register_schema( except AttributeError: pass - logging_enable = kwargs.pop("logging_enable", False) + http_request_keywords = ["params", "headers", "json", "data", "files"] + http_request_kwargs = {key: kwargs.pop(key) for key in http_request_keywords if key in kwargs} request = schema_rest.build_register_request( group_name=group_name, schema_name=name, content=schema_definition, serialization_type=format, content_type=kwargs.pop("content_type", "application/json"), - **kwargs + **http_request_kwargs ) - response = await self._generated_client.send_request(request, logging_enable=logging_enable) + response = await self._generated_client.send_request(request, **kwargs) response.raise_for_status() return _parse_response_schema_properties(response) @@ -152,7 +153,9 @@ async def get_schema( :caption: Get schema by id. """ - request = schema_rest.build_get_by_id_request(schema_id=id) + http_request_keywords = ["params", "headers", "json", "data", "files"] + http_request_kwargs = {key: kwargs.pop(key, None) for key in http_request_keywords if key in kwargs} + request = schema_rest.build_get_by_id_request(schema_id=id, **http_request_kwargs) response = await self._generated_client.send_request(request, **kwargs) response.raise_for_status() return _parse_response_schema(response) @@ -191,16 +194,17 @@ async def get_schema_properties( except AttributeError: pass - logging_enable = kwargs.pop("logging_enable", False) + http_request_keywords = ["params", "headers", "json", "data", "files"] + http_request_kwargs = {key: kwargs.pop(key, None) for key in http_request_keywords if key in kwargs} request = schema_rest.build_query_id_by_content_request( group_name=group_name, schema_name=name, content=schema_definition, serialization_type=format, content_type=kwargs.pop("content_type", "application/json"), - **kwargs + **http_request_kwargs ) - response = await self._generated_client.send_request(request, logging_enable=logging_enable, **kwargs) + response = await self._generated_client.send_request(request, **kwargs) response.raise_for_status() return _parse_response_schema_properties(response) From a3e6a022527fb005d57ecbc973f22f170e91a164 Mon Sep 17 00:00:00 2001 From: Swathi Pillalamarri Date: Tue, 2 Nov 2021 08:46:21 -0700 Subject: [PATCH 3/5] move to helper --- .../azure/schemaregistry/_schema_registry_client.py | 10 ++++------ .../azure/schemaregistry/_utils.py | 9 +++++++++ .../aio/_schema_registry_client_async.py | 10 ++++------ 3 files changed, 17 insertions(+), 12 deletions(-) create mode 100644 sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_utils.py diff --git a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_schema_registry_client.py b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_schema_registry_client.py index caf99637f312..c9ed4cb87ef8 100644 --- a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_schema_registry_client.py +++ b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_schema_registry_client.py @@ -25,6 +25,7 @@ # -------------------------------------------------------------------------- from typing import Any, TYPE_CHECKING, Union +from ._utils import get_http_request_kwargs from ._common._constants import SchemaFormat from ._common._schema import Schema, SchemaProperties from ._common._response_handlers import ( @@ -114,8 +115,7 @@ def register_schema( except AttributeError: pass - http_request_keywords = ["params", "headers", "json", "data", "files"] - http_request_kwargs = {key: kwargs.pop(key, None) for key in http_request_keywords if key in kwargs} + http_request_kwargs = get_http_request_kwargs(kwargs) request = schema_rest.build_register_request( group_name=group_name, schema_name=name, @@ -148,8 +148,7 @@ def get_schema(self, id, **kwargs): # pylint:disable=redefined-builtin :caption: Get schema by id. """ - http_request_keywords = ["params", "headers", "json", "data", "files"] - http_request_kwargs = {key: kwargs.pop(key, None) for key in http_request_keywords if key in kwargs} + http_request_kwargs = get_http_request_kwargs(kwargs) request = schema_rest.build_get_by_id_request(schema_id=id, **http_request_kwargs) response = self._generated_client.send_request(request, **kwargs) response.raise_for_status() @@ -185,8 +184,7 @@ def get_schema_properties( except AttributeError: pass - http_request_keywords = ["params", "headers", "json", "data", "files"] - http_request_kwargs = {key: kwargs.pop(key, None) for key in http_request_keywords if key in kwargs} + http_request_kwargs = get_http_request_kwargs(kwargs) request = schema_rest.build_query_id_by_content_request( group_name=group_name, schema_name=name, diff --git a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_utils.py b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_utils.py new file mode 100644 index 000000000000..d041e5c75f69 --- /dev/null +++ b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_utils.py @@ -0,0 +1,9 @@ +# -------------------------------------------------------------------------------------------- +# Copyright (c) Microsoft Corporation. All rights reserved. +# Licensed under the MIT License. See License.txt in the project root for license information. +# -------------------------------------------------------------------------------------------- + +def get_http_request_kwargs(kwargs): + http_request_keywords = ["params", "headers", "json", "data", "files"] + http_request_kwargs = {key: kwargs.pop(key, None) for key in http_request_keywords if key in kwargs} + return http_request_kwargs diff --git a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/aio/_schema_registry_client_async.py b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/aio/_schema_registry_client_async.py index a1508a89c4e3..0eac4100df03 100644 --- a/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/aio/_schema_registry_client_async.py +++ b/sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/aio/_schema_registry_client_async.py @@ -25,6 +25,7 @@ # -------------------------------------------------------------------------- from typing import Any, TYPE_CHECKING, Union +from .._utils import get_http_request_kwargs from .._common._constants import SchemaFormat from .._common._schema import Schema, SchemaProperties from .._common._response_handlers import ( @@ -116,8 +117,7 @@ async def register_schema( except AttributeError: pass - http_request_keywords = ["params", "headers", "json", "data", "files"] - http_request_kwargs = {key: kwargs.pop(key) for key in http_request_keywords if key in kwargs} + http_request_kwargs = get_http_request_kwargs(kwargs) request = schema_rest.build_register_request( group_name=group_name, schema_name=name, @@ -153,8 +153,7 @@ async def get_schema( :caption: Get schema by id. """ - http_request_keywords = ["params", "headers", "json", "data", "files"] - http_request_kwargs = {key: kwargs.pop(key, None) for key in http_request_keywords if key in kwargs} + http_request_kwargs = get_http_request_kwargs(kwargs) request = schema_rest.build_get_by_id_request(schema_id=id, **http_request_kwargs) response = await self._generated_client.send_request(request, **kwargs) response.raise_for_status() @@ -194,8 +193,7 @@ async def get_schema_properties( except AttributeError: pass - http_request_keywords = ["params", "headers", "json", "data", "files"] - http_request_kwargs = {key: kwargs.pop(key, None) for key in http_request_keywords if key in kwargs} + http_request_kwargs = get_http_request_kwargs(kwargs) request = schema_rest.build_query_id_by_content_request( group_name=group_name, schema_name=name, From f6359f7936e2793430625d9688498d5e1341b1ae Mon Sep 17 00:00:00 2001 From: Swathi Pillalamarri Date: Tue, 2 Nov 2021 08:57:43 -0700 Subject: [PATCH 4/5] update samples/tests with logging --- .../samples/async_samples/schema_registry_async.py | 4 ++-- .../samples/sync_samples/schema_registry.py | 4 ++-- .../tests/async_tests/test_schema_registry_async.py | 6 +++--- .../azure-schemaregistry/tests/test_schema_registry.py | 6 +++--- 4 files changed, 10 insertions(+), 10 deletions(-) diff --git a/sdk/schemaregistry/azure-schemaregistry/samples/async_samples/schema_registry_async.py b/sdk/schemaregistry/azure-schemaregistry/samples/async_samples/schema_registry_async.py index 6a156865647c..5adcb935c46c 100644 --- a/sdk/schemaregistry/azure-schemaregistry/samples/async_samples/schema_registry_async.py +++ b/sdk/schemaregistry/azure-schemaregistry/samples/async_samples/schema_registry_async.py @@ -39,7 +39,7 @@ async def register_schema(client, group_name, name, schema_string, format): async def get_schema_by_id(client, id): print("Getting schema by id...") - schema = await client.get_schema(id) + schema = await client.get_schema(id, logging_enable=True) print("The schema string of schema id: {} string is {}".format(id, schema.schema_definition)) print("Schema properties are {}".format(id)) return schema.schema_definition @@ -59,7 +59,7 @@ async def main(): client_id=CLIENT_ID, client_secret=CLIENT_SECRET ) - schema_registry_client = SchemaRegistryClient(fully_qualified_namespace=SCHEMAREGISTRY_FQN, credential=token_credential) + schema_registry_client = SchemaRegistryClient(fully_qualified_namespace=SCHEMAREGISTRY_FQN, credential=token_credential, logging_enable=True) async with token_credential, schema_registry_client: schema_id = await register_schema(schema_registry_client, GROUP_NAME, NAME, SCHEMA_STRING, FORMAT) schema_str = await get_schema_by_id(schema_registry_client, schema_id) diff --git a/sdk/schemaregistry/azure-schemaregistry/samples/sync_samples/schema_registry.py b/sdk/schemaregistry/azure-schemaregistry/samples/sync_samples/schema_registry.py index 842cfc694e21..12b28189c2a4 100644 --- a/sdk/schemaregistry/azure-schemaregistry/samples/sync_samples/schema_registry.py +++ b/sdk/schemaregistry/azure-schemaregistry/samples/sync_samples/schema_registry.py @@ -79,7 +79,7 @@ def register_schema(client, group_name, name, schema_string, format): def get_schema_by_id(client, id): print("Getting schema by id...") - schema = client.get_schema(id) + schema = client.get_schema(id, logging_enable=True) print("The schema string of schema id: {} string is {}".format(id, schema.schema_definition)) print("Schema properties are {}".format(id)) return schema.schema_definition @@ -99,7 +99,7 @@ def get_schema_id(client, group_name, name, schema_string, format): client_id=CLIENT_ID, client_secret=CLIENT_SECRET ) - schema_registry_client = SchemaRegistryClient(fully_qualified_namespace=SCHEMAREGISTRY_FQN, credential=token_credential) + schema_registry_client = SchemaRegistryClient(fully_qualified_namespace=SCHEMAREGISTRY_FQN, credential=token_credential, logging_enable=True) with schema_registry_client: schema_id = register_schema(schema_registry_client, GROUP_NAME, NAME, SCHEMA_STRING, FORMAT) schema_str = get_schema_by_id(schema_registry_client, schema_id) diff --git a/sdk/schemaregistry/azure-schemaregistry/tests/async_tests/test_schema_registry_async.py b/sdk/schemaregistry/azure-schemaregistry/tests/async_tests/test_schema_registry_async.py index 01b08ff2b6e4..66e165b04c51 100644 --- a/sdk/schemaregistry/azure-schemaregistry/tests/async_tests/test_schema_registry_async.py +++ b/sdk/schemaregistry/azure-schemaregistry/tests/async_tests/test_schema_registry_async.py @@ -47,20 +47,20 @@ async def test_schema_basic_async(self, schemaregistry_fully_qualified_namespace schema_name = self.get_resource_name('test-schema-basic-async') schema_str = """{"namespace":"example.avro","type":"record","name":"User","fields":[{"name":"name","type":"string"},{"name":"favorite_number","type":["int","null"]},{"name":"favorite_color","type":["string","null"]}]}""" format = "Avro" - schema_properties = await client.register_schema(schemaregistry_group, schema_name, schema_str, format) + schema_properties = await client.register_schema(schemaregistry_group, schema_name, schema_str, format, logging_enable=True) assert schema_properties.id is not None assert schema_properties.version is 1 assert schema_properties.format == "Avro" - returned_schema = await client.get_schema(id=schema_properties.id) + returned_schema = await client.get_schema(id=schema_properties.id, logging_enable=True) assert returned_schema.properties.id == schema_properties.id assert returned_schema.properties.version == 1 assert returned_schema.properties.format == "Avro" assert returned_schema.schema_definition == schema_str - returned_schema_properties = await client.get_schema_properties(schemaregistry_group, schema_name, schema_str, format) + returned_schema_properties = await client.get_schema_properties(schemaregistry_group, schema_name, schema_str, format, logging_enable=True) assert returned_schema_properties.id == schema_properties.id assert returned_schema_properties.version == 1 diff --git a/sdk/schemaregistry/azure-schemaregistry/tests/test_schema_registry.py b/sdk/schemaregistry/azure-schemaregistry/tests/test_schema_registry.py index 907617a311bf..26a3ff971aff 100644 --- a/sdk/schemaregistry/azure-schemaregistry/tests/test_schema_registry.py +++ b/sdk/schemaregistry/azure-schemaregistry/tests/test_schema_registry.py @@ -42,20 +42,20 @@ def test_schema_basic(self, schemaregistry_fully_qualified_namespace, schemaregi schema_name = self.get_resource_name('test-schema-basic') schema_str = """{"namespace":"example.avro","type":"record","name":"User","fields":[{"name":"name","type":"string"},{"name":"favorite_number","type":["int","null"]},{"name":"favorite_color","type":["string","null"]}]}""" format = "Avro" - schema_properties = client.register_schema(schemaregistry_group, schema_name, schema_str, format) + schema_properties = client.register_schema(schemaregistry_group, schema_name, schema_str, format, logging_enable=True) assert schema_properties.id is not None assert schema_properties.version is 1 assert schema_properties.format == "Avro" - returned_schema = client.get_schema(id=schema_properties.id) + returned_schema = client.get_schema(id=schema_properties.id, logging_enable=True) assert returned_schema.properties.id == schema_properties.id assert returned_schema.properties.version == 1 assert returned_schema.properties.format == "Avro" assert returned_schema.schema_definition == schema_str - returned_schema_properties = client.get_schema_properties(schemaregistry_group, schema_name, schema_str, format) + returned_schema_properties = client.get_schema_properties(schemaregistry_group, schema_name, schema_str, format, logging_enable=True) assert returned_schema_properties.id == schema_properties.id assert returned_schema_properties.version == 1 From f754fcba3081a169145dcad1bc38b68cd5b6612e Mon Sep 17 00:00:00 2001 From: Swathi Pillalamarri Date: Tue, 2 Nov 2021 11:02:08 -0700 Subject: [PATCH 5/5] remove from samples --- .../samples/async_samples/schema_registry_async.py | 4 ++-- .../samples/sync_samples/schema_registry.py | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/sdk/schemaregistry/azure-schemaregistry/samples/async_samples/schema_registry_async.py b/sdk/schemaregistry/azure-schemaregistry/samples/async_samples/schema_registry_async.py index 5adcb935c46c..6a156865647c 100644 --- a/sdk/schemaregistry/azure-schemaregistry/samples/async_samples/schema_registry_async.py +++ b/sdk/schemaregistry/azure-schemaregistry/samples/async_samples/schema_registry_async.py @@ -39,7 +39,7 @@ async def register_schema(client, group_name, name, schema_string, format): async def get_schema_by_id(client, id): print("Getting schema by id...") - schema = await client.get_schema(id, logging_enable=True) + schema = await client.get_schema(id) print("The schema string of schema id: {} string is {}".format(id, schema.schema_definition)) print("Schema properties are {}".format(id)) return schema.schema_definition @@ -59,7 +59,7 @@ async def main(): client_id=CLIENT_ID, client_secret=CLIENT_SECRET ) - schema_registry_client = SchemaRegistryClient(fully_qualified_namespace=SCHEMAREGISTRY_FQN, credential=token_credential, logging_enable=True) + schema_registry_client = SchemaRegistryClient(fully_qualified_namespace=SCHEMAREGISTRY_FQN, credential=token_credential) async with token_credential, schema_registry_client: schema_id = await register_schema(schema_registry_client, GROUP_NAME, NAME, SCHEMA_STRING, FORMAT) schema_str = await get_schema_by_id(schema_registry_client, schema_id) diff --git a/sdk/schemaregistry/azure-schemaregistry/samples/sync_samples/schema_registry.py b/sdk/schemaregistry/azure-schemaregistry/samples/sync_samples/schema_registry.py index 12b28189c2a4..842cfc694e21 100644 --- a/sdk/schemaregistry/azure-schemaregistry/samples/sync_samples/schema_registry.py +++ b/sdk/schemaregistry/azure-schemaregistry/samples/sync_samples/schema_registry.py @@ -79,7 +79,7 @@ def register_schema(client, group_name, name, schema_string, format): def get_schema_by_id(client, id): print("Getting schema by id...") - schema = client.get_schema(id, logging_enable=True) + schema = client.get_schema(id) print("The schema string of schema id: {} string is {}".format(id, schema.schema_definition)) print("Schema properties are {}".format(id)) return schema.schema_definition @@ -99,7 +99,7 @@ def get_schema_id(client, group_name, name, schema_string, format): client_id=CLIENT_ID, client_secret=CLIENT_SECRET ) - schema_registry_client = SchemaRegistryClient(fully_qualified_namespace=SCHEMAREGISTRY_FQN, credential=token_credential, logging_enable=True) + schema_registry_client = SchemaRegistryClient(fully_qualified_namespace=SCHEMAREGISTRY_FQN, credential=token_credential) with schema_registry_client: schema_id = register_schema(schema_registry_client, GROUP_NAME, NAME, SCHEMA_STRING, FORMAT) schema_str = get_schema_by_id(schema_registry_client, schema_id)