Migrate Event Hub SDK to central Repo

.azure-pipelines/client.test.live.yml

@@ -31,10 +31,21 @@ jobs:
       - script: 'pytest -m liveTest $(ServicePackage)'
         displayName: 'Run test suite'
         env:
+          # Service Bus Variables
           SERVICE_BUS_HOSTNAME: $(python-sb-livetest-service-bus-hostname)
           SERVICE_BUS_SAS_POLICY: $(python-sb-livetest-service-sas-policy)
           SERVICE_BUS_SAS_KEY: $(python-sb-livetest-service-sas-key)
           SERVICE_BUS_CONNECTION_STR: $(python-sb-livetest-service-connection-str)
           SERVICE_BUS_CONNECTION_STR_RO: $(python-sb-livetest-service-connection-str-ro)
           SERVICE_BUS_CONNECTION_STR_WO: $(python-sb-livetest-service-connection-str-wo)
           SERVICE_BUS_CONNECTION_STR_ENTITY: $(python-sb-livetest-service-connection-entity)
+          # Event Hubs Variables
+          AZURE_STORAGE_ACCOUNT: $(python-eh-livetest-event-hub-storage-account)
+          AZURE_STORAGE_ACCESS_KEY: $(python-eh-livetest-event-hub-storage-access-key)
+          EVENT_HUB_HOSTNAME: $(python-eh-livetest-event-hub-hostname)
+          EVENT_HUB_NAME: $(python-eh-livetest-event-hub-name)
+          EVENT_HUB_SAS_POLICY: $(python-eh-livetest-event-hub-sas-policy)
+          EVENT_HUB_SAS_KEY: $(python-eh-livetest-event-hub-sas-key)
+          EVENT_HUB_NAMESPACE: $(python-eh-livetest-event-hub-namespace)
+          IOTHUB_CONNECTION_STR: $(python-eh-livetest-event-hub-iothub-connection-str)
+          IOTHUB_DEVICE: $(python-eh-livetest-event-hub-iothub-device)

azure-eventhubs/HISTORY.rst

@@ -0,0 +1,138 @@
+.. :changelog:
+
+Release History
+===============
+
+1.3.1 (2019-02-28)
+------------------
+
+**BugFixes**
+
+- Fixed bug where datetime offset filter was using a local timestamp rather than UTC.
+- Fixed stackoverflow error in continuous connection reconnect attempts.
+
+
+1.3.0 (2019-01-29)
+------------------
+
+**Bugfixes**
+
+- Added support for auto reconnect on token expiration and other auth errors (issue #89).
+
+**Features**
+
+- Added ability to create ServiceBusClient from an existing SAS auth token, including
+  provding a function to auto-renew that token on expiry.
+- Added support for storing a custom EPH context value in checkpoint (PR #84, thanks @konstantinmiller)
+
+
+1.2.0 (2018-11-29)
+------------------
+
+- Support for Python 2.7 in azure.eventhub module (azure.eventprocessorhost will not support Python 2.7).
+- Parse EventData.enqueued_time as a UTC timestamp (issue #72, thanks @vjrantal)
+
+
+1.1.1 (2018-10-03)
+------------------
+
+- Fixed bug in Azure namespace package.
+
+
+1.1.0 (2018-09-21)
+------------------
+
+- Changes to `AzureStorageCheckpointLeaseManager` parameters to support other connection options (issue #61):
+
+  - The `storage_account_name`, `storage_account_key` and `lease_container_name` arguments are now optional keyword arguments.
+  - Added a `sas_token` argument that must be specified with `storage_account_name` in place of `storage_account_key`.
+  - Added an `endpoint_suffix` argument to support storage endpoints in National Clouds.
+  - Added a `connection_string` argument that, if specified, overrides all other endpoint arguments.
+  - The `lease_container_name` argument now defaults to `"eph-leases"` if not specified.
+
+- Fix for clients failing to start if run called multipled times (issue #64).
+- Added convenience methods `body_as_str` and `body_as_json` to EventData object for easier processing of message data.
+
+
+1.0.0 (2018-08-22)
+------------------
+
+- API stable.
+- Renamed internal `_async` module to `async_ops` for docs generation.
+- Added optional `auth_timeout` parameter to `EventHubClient` and `EventHubClientAsync` to configure how long to allow for token
+  negotiation to complete. Default is 60 seconds.
+- Added optional `send_timeout` parameter to `EventHubClient.add_sender` and `EventHubClientAsync.add_async_sender` to determine the
+  timeout for Events to be successfully sent. Default value is 60 seconds.
+- Reformatted logging for performance.
+
+
+0.2.0 (2018-08-06)
+------------------
+
+- Stability improvements for EPH.
+- Updated uAMQP version.
+- Added new configuration options for Sender and Receiver; `keep_alive` and `auto_reconnect`.
+  These flags have been added to the following:
+
+  - `EventHubClient.add_receiver`
+  - `EventHubClient.add_sender`
+  - `EventHubClientAsync.add_async_receiver`
+  - `EventHubClientAsync.add_async_sender`
+  - `EPHOptions.keey_alive_interval`
+  - `EPHOptions.auto_reconnect_on_error`
+
+
+0.2.0rc2 (2018-07-29)
+---------------------
+
+- **Breaking change** `EventData.offset` will now return an object of type `~uamqp.common.Offset` rather than str.
+  The original string value can be retrieved from `~uamqp.common.Offset.value`.
+- Each sender/receiver will now run in its own independent connection.
+- Updated uAMQP dependency to 0.2.0
+- Fixed issue with IoTHub clients not being able to retrieve partition information.
+- Added support for HTTP proxy settings to both EventHubClient and EPH.
+- Added error handling policy to automatically reconnect on retryable error.
+- Added keep-alive thread for maintaining an unused connection.
+
+
+0.2.0rc1 (2018-07-06)
+---------------------
+
+- **Breaking change** Restructured library to support Python 3.7. Submodule `async` has been renamed and all classes from
+  this module can now be imported from azure.eventhub directly.
+- **Breaking change** Removed optional `callback` argument from `Receiver.receive` and `AsyncReceiver.receive`.
+- **Breaking change** `EventData.properties` has been renamed to `EventData.application_properties`.
+  This removes the potential for messages to be processed via callback for not yet returned
+  in the batch.
+- Updated uAMQP dependency to v0.1.0
+- Added support for constructing IoTHub connections.
+- Fixed memory leak in receive operations.
+- Dropped Python 2.7 wheel support.
+
+
+0.2.0b2 (2018-05-29)
+--------------------
+
+- Added `namespace_suffix` to EventHubConfig() to support national clouds.
+- Added `device_id` attribute to EventData to support IoT Hub use cases.
+- Added message header to workaround service bug for PartitionKey support.
+- Updated uAMQP dependency to vRC1.
+
+
+0.2.0b1 (2018-04-20)
+--------------------
+
+- Updated uAMQP to latest version.
+- Further testing and minor bug fixes.
+
+
+0.2.0a2 (2018-04-02)
+--------------------
+
+- Updated uAQMP dependency.
+
+
+0.2.0a1 (unreleased)
+--------------------
+
+- Swapped out Proton dependency for uAMQP.

azure-eventhubs/LICENSE

@@ -0,0 +1,21 @@
+    MIT License
+
+    Copyright (c) Microsoft Corporation. All rights reserved.
+
+    Permission is hereby granted, free of charge, to any person obtaining a copy
+    of this software and associated documentation files (the "Software"), to deal
+    in the Software without restriction, including without limitation the rights
+    to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+    copies of the Software, and to permit persons to whom the Software is
+    furnished to do so, subject to the following conditions:
+
+    The above copyright notice and this permission notice shall be included in all
+    copies or substantial portions of the Software.
+
+    THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+    IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+    FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+    AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+    LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+    OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+    SOFTWARE

azure-eventhubs/MANIFEST.in

@@ -0,0 +1,2 @@
+include *.rst
+include azure/__init__.py