Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Schema Registry + Avro Serializer] 1.0.0b1 #13124

Merged
merged 36 commits into from
Sep 4, 2020
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
36 commits
Select commit Hold shift + click to select a range
56bf5eb
init commit
yunhaoling Aug 14, 2020
d1c96f9
avro serializer structure
yunhaoling Aug 18, 2020
6311e92
adding avro serializer
yunhaoling Aug 20, 2020
0096ef2
tweak api version and fix a typo
yunhaoling Aug 20, 2020
2e95001
test template
yunhaoling Aug 21, 2020
2e8bcc7
avro serializer sync draft
yunhaoling Aug 22, 2020
6248ff1
major azure sr client work done
yunhaoling Aug 25, 2020
f97478e
add sample docstring for sr
yunhaoling Aug 25, 2020
3cf6459
avro serializer async impl
yunhaoling Aug 26, 2020
58fb59f
close the writer
yunhaoling Aug 26, 2020
02c60ec
update avro se/de impl
yunhaoling Aug 27, 2020
85d6766
update avro serializer impl
yunhaoling Aug 27, 2020
5fa4b43
fix apireview reported error in sr
yunhaoling Aug 27, 2020
b910027
srav namespace, setup update
yunhaoling Aug 27, 2020
6b6c8b2
doc update
yunhaoling Aug 28, 2020
c465be1
update doc and api
yunhaoling Aug 30, 2020
63a278c
impl, doc update
yunhaoling Aug 31, 2020
dc363f4
partial update according to laruent's feedback
yunhaoling Sep 1, 2020
740de0e
be consistent with eh extension structure
yunhaoling Sep 1, 2020
7734c42
more update code according to feedback
yunhaoling Sep 1, 2020
92cd385
update credential config
yunhaoling Sep 1, 2020
1c60676
rename package name to azure-schemaregistry-avroserializer
yunhaoling Sep 1, 2020
f20bba0
fix pylint
yunhaoling Sep 1, 2020
c81f16b
try ci fix
yunhaoling Sep 2, 2020
41ee64b
fix test for py27 as avro only accept unicode
yunhaoling Sep 3, 2020
2675331
first round of review feedback
yunhaoling Sep 3, 2020
fb0e6f9
remove temp ci experiment
yunhaoling Sep 3, 2020
0260ea3
init add conftest.py to pass py2.7 test
yunhaoling Sep 3, 2020
bb687cb
laurent feedback update
yunhaoling Sep 3, 2020
d8e0986
remove dictmixin for b1, update comment in sample
yunhaoling Sep 3, 2020
b91fb4f
update api in avroserializer and update test and readme
yunhaoling Sep 4, 2020
929ee68
update test, docs and links
yunhaoling Sep 4, 2020
8fbed90
add share requirement
yunhaoling Sep 4, 2020
01a39a7
update avro dependency
yunhaoling Sep 4, 2020
bde3c24
pr feedback and livetest update
yunhaoling Sep 4, 2020
a2903b6
Merge remote-tracking branch 'central/master' into sr-dev
yunhaoling Sep 4, 2020
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
doc update
  • Loading branch information
yunhaoling committed Aug 28, 2020
commit 6b6c8b2328b187dedf0916df790e26e672ca64da
Original file line number Diff line number Diff line change
Expand Up @@ -34,8 +34,6 @@

class SchemaRegistryAvroSerializer(object):
"""
SchemaRegistryClient is as a central schema repository for enterprise-level data infrastructure,
complete with support for versioning and management.

:param str endpoint: The Schema Registry service endpoint, for example my-namespace.servicebus.windows.net.
:param credential: To authenticate to manage the entities of the SchemaRegistry namespace.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@
install_requires=[
'azure-core<2.0.0,>=1.2.2',
'azure-schemaregistry<2.0.0,>=1.0.0b1',
'avro>=1.0.0'
'avro<2.0.0,>=1.0.0'
],
extras_require={
":python_version<'3.0'": ['azure-nspkg', 'futures'],
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ class SchemaRegistryAvroSerializerTests(AzureMgmtTestCase):

@pytest.mark.liveTest
@pytest.mark.live_test_only
def test_basic_avro_serializer(self):
def test_raw_avro_serializer(self):
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"]}]}"""
schema = avro.schema.parse(schema_str)
dict_data = {"name": "Ben", "favorite_number": 7, "favorite_color": "red"}
Expand All @@ -57,6 +57,9 @@ def test_basic_avro_serializer(self):
assert decoded_data['favorite_number'] == 7
assert decoded_data['favorite_color'] == 'red'




@pytest.mark.liveTest
@pytest.mark.live_test_only
@SchemaRegistryPreparer()
def test_basic_sr_avro_serializer(self, schemaregistry_endpoint, schemaregistry_group, schemaregistry_tenant_id,
schemaregistry_client_id, schemaregistry_client_secret, **kwargs):
pass