Skip to content
This repository was archived by the owner on Oct 12, 2023. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
58 commits
Select commit Hold shift + click to select a range
fab331c
Disallow a sender/receiver to be registered more than once
xinchen10 Jan 3, 2018
9ff35b6
Make everything async in EPH
itamar-otonomo Feb 15, 2018
479601c
#25 Partition key cannot be set for events
xinchen10 Mar 28, 2018
e5f1a4d
Started removing proton code
annatisch Mar 7, 2018
4f3beb0
Removed most of proton _impl
annatisch Mar 7, 2018
d6fbfc2
Removed more code
annatisch Mar 7, 2018
d5027ec
Working sender
annatisch Mar 9, 2018
03054bf
Updates to sender
annatisch Mar 9, 2018
7d42f3e
Added some tests/samples
annatisch Mar 13, 2018
6be5ec6
Some progress on clients
annatisch Mar 13, 2018
6abb516
Fixed samples
annatisch Mar 13, 2018
9cb0491
Added azure namespace
annatisch Mar 19, 2018
39531eb
Updated version
annatisch Mar 19, 2018
87b5fb5
Updated README
annatisch Mar 19, 2018
20dcb3a
Renamed package to eventhub
annatisch Mar 19, 2018
568f9c6
Started EPH modifications
annatisch Mar 19, 2018
fca3222
Updated imports
annatisch Mar 20, 2018
f96b5f0
Fixed target urls
annatisch Mar 20, 2018
098e0d9
Updated logging
annatisch Mar 20, 2018
547f830
Updated async message receive
annatisch Mar 20, 2018
4cf927a
updated test imports
annatisch Mar 20, 2018
3942666
Added mgmt call to get eh info
annatisch Mar 21, 2018
bd2a16b
Updated samples
annatisch Mar 21, 2018
66041cb
Updated receive test
annatisch Mar 23, 2018
9968136
Added send and receive test clients
annatisch Mar 23, 2018
78a9de2
Updated uamqp dependency
annatisch Mar 24, 2018
768eaca
Merged updates from dev
annatisch Mar 26, 2018
f0e75f0
Fixed typos
annatisch Mar 26, 2018
4905a1c
Updated EPH sample
annatisch Mar 26, 2018
27d3391
Started docstrings
annatisch Mar 27, 2018
e54f4da
Converted tests to pytest
annatisch Mar 28, 2018
70bb64f
Updates to batch receive
annatisch Mar 30, 2018
3fc1c93
Started adding docstrings
annatisch Apr 3, 2018
2e183e2
More docstrings
annatisch Apr 4, 2018
82978a8
bumped version
annatisch Apr 4, 2018
bbb6fc4
Started porting test suite
annatisch Apr 10, 2018
9991ba0
More tests and improvements
annatisch Apr 10, 2018
e706412
Moved eph tests
annatisch Apr 11, 2018
31160cd
Some sample cleanup
annatisch Apr 11, 2018
80176fa
Some test updates
annatisch Apr 12, 2018
faaf2b3
Some test restructure
annatisch Apr 12, 2018
ba2cb48
Docstring cleanup
annatisch Apr 17, 2018
b70f124
Fixed some merge artifacts
annatisch Apr 17, 2018
ed16b06
Fixed formatting error
annatisch Apr 17, 2018
e54df41
Removed delivery count
annatisch Apr 20, 2018
0d4dedf
Nested package directory
annatisch May 15, 2018
05edf41
Support custom URL suffix
annatisch May 16, 2018
cea77d3
Support custom URL suffix
annatisch May 16, 2018
110245b
Support for EventData device ID
annatisch May 18, 2018
126d2e0
Reverted nested directory
annatisch May 18, 2018
a9577c6
Updated release notes
annatisch May 18, 2018
3bfb92f
Workaround for partitionkey
annatisch May 23, 2018
90195a0
Finished partition key workaround
annatisch May 24, 2018
f310841
beta2 fixes
annatisch May 29, 2018
0170ddf
pylint fixes
annatisch May 29, 2018
37443c8
Trigger CI
annatisch May 29, 2018
077fe12
Test fixes
annatisch May 29, 2018
3e3c569
Added package manifest
annatisch May 29, 2018
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
8 changes: 7 additions & 1 deletion .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ __pycache__/

# Distribution / packaging
.Python
env/
env*/
build/
develop-eggs/
dist/
Expand Down Expand Up @@ -36,6 +36,10 @@ pip-log.txt
pip-delete-this-directory.txt

# Unit test / coverage reports
azure/storage/
azure/common/
azure/profiles/

htmlcov/
.tox/
.coverage
Expand Down Expand Up @@ -99,3 +103,5 @@ ENV/

# mypy
.mypy_cache/
.pytest_cache/v/cache/lastfailed
.pytest_cache/v/cache/nodeids
13 changes: 13 additions & 0 deletions .travis.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,13 @@
language: python
cache: pip
python:
- "3.6"
# command to install dependencies
install:
- pip install -r dev_requirements.txt
- pip install -e .
script:
- pytest
- python ./setup.py check -r -s
- pylint azure.eventhub
- pylint azure.eventprocessorhost
31 changes: 31 additions & 0 deletions HISTORY.rst
Original file line number Diff line number Diff line change
@@ -0,0 +1,31 @@
.. :changelog:
Release History
===============

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.
1 change: 1 addition & 0 deletions MANIFEST.in
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
include *.rst
53 changes: 0 additions & 53 deletions README.md

This file was deleted.

64 changes: 64 additions & 0 deletions README.rst
Original file line number Diff line number Diff line change
@@ -0,0 +1,64 @@
Microsoft Azure SDK for Event Hubs
==================================

A Python AMQP client for Azure Event Hubs the provides:

- A sender to publish events to the Event Hubs service.
- A receiver to read events from the Event Hubs service.

On Python 3.5 and above, it also includes:

- An async sender and receiver that supports async/await methods.
- An Event Processor Host module that manages the distribution of partition readers.


Installation
============

Wheels are provided for all major operating systems, so you can install directly with pip:

.. code:: shell
$ pip install azure-eventhub
Examples
+++++++++

- ./examples/send.py - use sender to publish events
- ./examples/recv.py - use receiver to read events
- ./examples/send_async.py - async/await support of a sender
- ./examples/recv_async.py - async/await support of a receiver
- ./examples/eph.py - event processor host


Logging
++++++++

- enable 'azure.eventhub' logger to collect traces from the library
- enable 'uamqp' logger to collect traces from the underlying uAMQP library
- enable AMQP frame level trace by setting `debug=True` when creating the Client


Provide Feedback
================

If you encounter any bugs or have suggestions, please file an issue in the
`Issues <https://github.com/Azure/azure-uamqp-python/issues>`__
section of the project.


Contributing
============

This project welcomes contributions and suggestions. Most contributions require you to agree to a
Contributor License Agreement (CLA) declaring that you have the right to, and actually do, grant us
the rights to use your contribution. For details, visit `https://cla.microsoft.com <https://cla.microsoft.com>`__.

When you submit a pull request, a CLA-bot will automatically determine whether you need to provide
a CLA and decorate the PR appropriately (e.g., label, comment). Simply follow the instructions
provided by the bot. You will only need to do this once across all repos using our CLA.

This project has adopted the `Microsoft Open Source Code of Conduct <https://opensource.microsoft.com/codeofconduct/>`__.
For more information see the `Code of Conduct FAQ <https://opensource.microsoft.com/codeofconduct/faq/>`__ or
contact `opencode@microsoft.com <mailto:opencode@microsoft.com>`__ with any additional questions or comments.
2 changes: 2 additions & 0 deletions azure/__init__.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@

__import__('pkg_resources').declare_namespace(__name__)
Loading