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.

Sign up for GitHub

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

Jump to bottom

[EventHubs] merge pyamqp to main #27763

Merged
merged 121 commits into from
Dec 13, 2022
Merged

[EventHubs] merge pyamqp to main #27763

merged 121 commits into from
Dec 13, 2022

Conversation

swathipil
Copy link
Member

merging pyamqp to main

swathipil and others added 30 commits July 12, 2021 15:08
@swathipil
[EventHub] basic receive event scenario with pyamqp (Azure#19748)
c6f446d 
* initial changes for receiving

* undo __init__ aio

* vendor

* remove c/pyx files

* adams comments
@yunhaoling
[EventHubs & AMQP Python] Send Port (Azure#19745)
4134fc0 
* draft send port

* copy and paste code changes in amqp

* simple stress test scripts for sending and receiving

* review feedbacks
@yunhaoling
[EventHubs&AMQP Python] Port amqp send large message (Azure#19937)
2aee77a 
* port amqp send large message

* send perf test in parallel

* use context manager for executor

* add throughput

* improve test code

* update test matrix

* update test

* handle server busy

* fix timeout

* precision to 2 decimal points

* update pyamqp changes and update tests
@yunhaoling
[EventHubs] Pure Python AMQP Sycn Implementation Integration (Azure#2…
f11cc0f 
…2397)

* copy amqp changes

* eh python amqp integration

* fix time unit

* rename module pyamqp to _pyamqp

* more pyamqp to _pyamqp

* simplify todo
@yunhaoling
merge main
67df9d8
@yunhaoling @swathipil
[EH Pyproto] Release preparation (Azure#22433)
5c90e0f 
* cherry pick changes

* update docs

* cherry pick fixed retry PR

* minor fix

* fix mypy, pylint, brokenlink

* update doc

* opt out mypy/pylint/api stub

* try opt out checkpointstore in ci and test

* fix

* more fixes

* furuther opt out tests

* update tests

* bump version

* fix __str__

* add test play holder

* ignore azure checkpoinstore aio in ci

Co-authored-by: swathipil <76007337+swathipil@users.noreply.github.com>
@yunhaoling
catch up with main and update release date
dc7e79c
@yunhaoling
update readme to drop uamqp
996e419
@yunhaoling
revert async tests
986d2a4
@yunhaoling
revert aio module in eventhub
e37fc23
@yunhaoling
merge main branch
0fb1af9
@yunhaoling
[EH Pyproto] Async support (Azure#22957)
934cb6e 
* async port

* add scripts for tests

* update async perf test scripts

* fix test scripts

* amqp implementation update + eh update + sync perf test scripts

* update pyamqp and eh async impl and test scripts

* update pyamqp async impl

* fix bug

* fix pyamqp transport ssl setting and asyncio exception module import

* use ensure future for 3.6

* update token generation to return bytes to avoid breaking changes

* update docs
@azure-sdk
Increment version for eventhub releases (Azure#22994)
e8bbe38 
Increment package version after release of azure-eventhub
@yunhaoling
merge central
fe47341
@yunhaoling
[EH Pyproto] Async recv perf improvement (Azure#23122)
2805d00 
* stop spawning too much coroutines

* improve send

* async recv perf improvement

* async perf improve

* update version

* align with sync imple

* update method name

* remove redundant except catch
@yunhaoling
[EH Pyproto] Release updates (Azure#23349)
17ea44b 
* update docs

* add todo
@azure-sdk
Increment version for eventhub releases (Azure#23420)
f5f9957 
Increment package version after release of azure-eventhub
@rakshith91 @swathipil
AMQP websocket implementation (Azure#23722)
0123f4d 
* Initial implementation

* http proxy support

* change impl

* more changes

* working sol

* async impl

* Update sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/_transport.py

* more changes

* sasl mixin

* Update sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/message.py

* refactor

* Update sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/_transport.py

* Update sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/_transport.py

* oops

* comments

* comment

* Apply suggestions from code review

Co-authored-by: swathipil <76007337+swathipil@users.noreply.github.com>

* comments

* changes

* async test

* rasie

* lint

* changelog

* version

* comments

* move path to EH

Co-authored-by: swathipil <76007337+swathipil@users.noreply.github.com>
@rakshith91
Revert "AMQP websocket implementation (Azure#23722)" (Azure#24344)
bcab241 
This reverts commit 0123f4d.
@rakshith91 @swathipil
AMQP websocket implementation (Azure#24345)
32566bd 
* Initial implementation

* http proxy support

* change impl

* more changes

* working sol

* async impl

* Update sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/_transport.py

* more changes

* sasl mixin

* Update sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/message.py

* refactor

* Update sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/_transport.py

* Update sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/_transport.py

* oops

* comments

* comment

* Apply suggestions from code review

Co-authored-by: swathipil <76007337+swathipil@users.noreply.github.com>

* comments

* changes

* async test

* rasie

* lint

* changelog

* version

* comments

* move path to EH

* Fix typo

Co-authored-by: swathipil <76007337+swathipil@users.noreply.github.com>
@swathipil @kashifkhan
[EventHub] basic receive event scenario with pyamqp (Azure#19748)
3fcef28 
* initial changes for receiving

* undo __init__ aio

* vendor

* remove c/pyx files

* adams comments
@yunhaoling @kashifkhan
[EventHubs & AMQP Python] Send Port (Azure#19745)
56d551a 
* draft send port

* copy and paste code changes in amqp

* simple stress test scripts for sending and receiving

* review feedbacks
@yunhaoling @kashifkhan
[EventHubs&AMQP Python] Port amqp send large message (Azure#19937)
92abbc0 
* port amqp send large message

* send perf test in parallel

* use context manager for executor

* add throughput

* improve test code

* update test matrix

* update test

* handle server busy

* fix timeout

* precision to 2 decimal points

* update pyamqp changes and update tests
@yunhaoling @kashifkhan
[EventHubs] Pure Python AMQP Sycn Implementation Integration (Azure#2…
dd96d59 
…2397)

* copy amqp changes

* eh python amqp integration

* fix time unit

* rename module pyamqp to _pyamqp

* more pyamqp to _pyamqp

* simplify todo
@yunhaoling @swathipil @kashifkhan
[EH Pyproto] Release preparation (Azure#22433)
e87e909 
* cherry pick changes

* update docs

* cherry pick fixed retry PR

* minor fix

* fix mypy, pylint, brokenlink

* update doc

* opt out mypy/pylint/api stub

* try opt out checkpointstore in ci and test

* fix

* more fixes

* furuther opt out tests

* update tests

* bump version

* fix __str__

* add test play holder

* ignore azure checkpoinstore aio in ci

Co-authored-by: swathipil <76007337+swathipil@users.noreply.github.com>
@yunhaoling @kashifkhan
update readme to drop uamqp
5ce4bd4
@yunhaoling @kashifkhan
revert async tests
cfa3f05
@yunhaoling @kashifkhan
revert aio module in eventhub
1ef957d
@yunhaoling @kashifkhan
[EH Pyproto] Async support (Azure#22957)
b14a063 
* async port

* add scripts for tests

* update async perf test scripts

* fix test scripts

* amqp implementation update + eh update + sync perf test scripts

* update pyamqp and eh async impl and test scripts

* update pyamqp async impl

* fix bug

* fix pyamqp transport ssl setting and asyncio exception module import

* use ensure future for 3.6

* update token generation to return bytes to avoid breaking changes

* update docs
@azure-sdk @kashifkhan
Increment version for eventhub releases (Azure#22994)
13bc27b 
Increment package version after release of azure-eventhub
@ghost ghost added the Event Hubs label Nov 30, 2022
@azure-sdk
Copy link
Collaborator

API change check

APIView has identified API level changes in this PR and created following API reviews.

azure-eventhub

@swathipil
Copy link
Member Author

/azp run python - eventhub - tests

@swathipil
Copy link
Member Author

/azp run python - eventhub - perf

@azure-pipelines
Copy link

Azure Pipelines successfully started running 1 pipeline(s).

1 similar comment
@azure-pipelines
Copy link

Azure Pipelines successfully started running 1 pipeline(s).

@swathipil
Copy link
Member Author

/azp run python - eventhub - tests

@azure-pipelines
Copy link

Azure Pipelines successfully started running 1 pipeline(s).

@swathipil
Copy link
Member Author

/azp run python - eventhub - tests

@azure-pipelines
Copy link

Azure Pipelines successfully started running 1 pipeline(s).

@swathipil
Copy link
Member Author

/azp run python - eventhub - tests

@azure-pipelines
Copy link

Azure Pipelines successfully started running 1 pipeline(s).

@swathipil
Copy link
Member Author

/azp run python - eventhub - tests

@azure-pipelines
Copy link

Azure Pipelines successfully started running 1 pipeline(s).

@swathipil
Copy link
Member Author

/azp run python - eventhub - ci

@azure-pipelines
Copy link

Azure Pipelines successfully started running 1 pipeline(s).

@swathipil swathipil marked this pull request as ready for review December 13, 2022 18:06
@swathipil swathipil merged commit d111b55 into Azure:main Dec 13, 2022
@swathipil swathipil deleted the swathipil/eh/merge-feature-main branch December 13, 2022 18:12
@kashifkhan kashifkhan mentioned this pull request Jan 3, 2023
Closed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers

@kashifkhan kashifkhan kashifkhan approved these changes

@scbedd scbedd Awaiting requested review from scbedd

@benbp benbp Awaiting requested review from benbp

@annatisch annatisch Awaiting requested review from annatisch annatisch is a code owner

@l0lawrence l0lawrence Awaiting requested review from l0lawrence l0lawrence is a code owner

Assignees
No one assigned
Labels
Event Hubs
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.
6 participants
@swathipil @azure-sdk @kashifkhan @yunhaoling @rakshith91 @l0lawrence