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

Event Hub Track 2 Support #74

Merged
merged 22 commits into from
May 20, 2019
Merged

Event Hub Track 2 Support #74

merged 22 commits into from
May 20, 2019

Conversation

yunhaoling
Copy link
Contributor

@yunhaoling yunhaoling commented May 13, 2019

@yunhaoling yunhaoling changed the title Event Hub Track2 Websocket support May 14, 2019
@yunhaoling yunhaoling marked this pull request as ready for review May 14, 2019 20:00
@yunhaoling yunhaoling changed the title Websocket support UAMQP Track 2 May 17, 2019
@yunhaoling yunhaoling changed the title UAMQP Track 2 Event Hub Track 2 Support May 17, 2019
Copy link
Member

@annatisch annatisch left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks @yunhaoling - looks good!
Just the one comment and we can merge :)

@@ -18,6 +19,8 @@
OPERATION = b"operation"
READ_OPERATION = b"READ"
MGMT_TARGET = b"$management"
EVENT_HUB_SCOPE = ['https://eventhubs.azure.net//.default']
SERVICE_BUS_SCOPE = ['https://servicebus.azure.net//.default']
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please remove these - we shouldn't keep references to Azure services in uAMQP. These should be passed through as values from EventHub or ServiceBus SDKs

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@annatisch Gotcha, just removed 😃

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I found Charles has updated the azure-identity, I need to do some modification to the JWTTokenAsync. I'll update you today when this pr is ready to merge.

annatisch added a commit that referenced this pull request Jun 13, 2019
* Bug fixes in client

* CI fixes

* More bug fixes + package updates

* Fixed pylint

* Fixed 2.7 pylint

* Fix memory leak problem in sending BatchEventData (#70)

* Missing application_properties in BatchMessage fixes

* Missing data bytes in BatchMessage fixes

* Updated pylint version

This should resolve Travis error: `AttributeError: 'Import' object has no attribute 'infer_name_module'`

* improve type checking to enable message-like objects in BatchMessage

* pylint error fixes

* remove Python 3.4 from the travis config as Python 3.4 won't be supported from the next release

* Fix memory leak in sending BatchEventData

* improve solution by typecasting NULL to AMQP types

* Remove explicit test directory

* Separate test passes

* Some test updates

* Turned off test debug

* Fixed proxy test

* Adding livetest yaml (#71)

* adding evenhub secrets to livetest for UAMQP

* Splitting client.yml into a livetest build with environment variables set + maxparallel set to 1. This will ensure that any livetests won't accidentally stomp on each other.

* Trying latest cython

* Reverting Cython version

* Conditionally Disable Py38 (#72)

* adding evenhub secrets to livetest for UAMQP

* trying an adjustment of the build to see if continueonError will work

* removing extra variables in client.yml

* missed a single addition

* regular variable access

* trying without quotes

* disabling python 3.8

* removing shenanigans with continueonerror

* fixing the ordering

* Event Hub Track 2 Support (#74)

* Missing application_properties in BatchMessage fixes

* Missing data bytes in BatchMessage fixes

* Updated pylint version

This should resolve Travis error: `AttributeError: 'Import' object has no attribute 'infer_name_module'`

* improve type checking to enable message-like objects in BatchMessage

* pylint error fixes

* remove Python 3.4 from the travis config as Python 3.4 won't be supported from the next release

* Fix memory leak in sending BatchEventData

* improve solution by typecasting NULL to AMQP types

* init commit for websocket support

* Websocket functionality done, but further design is needed

* Reorganzie WebSocket related code

* Remove unnecessary tls http_proxy setting

* Module import and proxy username password update

* Update comment

* Update code

* Fix pylint error

* OAuth support

* Add Message app_prop checking

* Remove scope

* Updated proxy test

* Event Hub Track 2 Support (#75)

* Missing application_properties in BatchMessage fixes

* Missing data bytes in BatchMessage fixes

* Updated pylint version

This should resolve Travis error: `AttributeError: 'Import' object has no attribute 'infer_name_module'`

* improve type checking to enable message-like objects in BatchMessage

* pylint error fixes

* remove Python 3.4 from the travis config as Python 3.4 won't be supported from the next release

* Fix memory leak in sending BatchEventData

* improve solution by typecasting NULL to AMQP types

* init commit for websocket support

* Websocket functionality done, but further design is needed

* Reorganzie WebSocket related code

* Remove unnecessary tls http_proxy setting

* Module import and proxy username password update

* Update comment

* Update code

* Fix pylint error

* OAuth support

* Add Message app_prop checking

* Remove scope

* Add async jwt token support

* Update max message size

* Fix pylint error

* Code improvement

* Fix mistake

* Update code
1. Add MessageContentTooLarge error and will be raised when BatchMessage content is too large
2. Remove useless raise in cbs_auth_async

* Update history

* Add missing raise and correct misspelling (#77)

* Fix livetest error and compatibility with EventHub Track1 (#78)

* Update prefetch count in test

* Fix getting loop bug

* Lower logging level as too many logs will cause memory error in test pipeline

* Update prefetch count for the live test

* Update pretech count

* Update docstring of timeout type from int to float as part of the guideline
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants