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

[Event Hubs] Update checkpoint store dependency on eventhubs to 5.0.0 for release #9423

Merged
merged 10 commits into from
Jan 13, 2020
Merged

[Event Hubs] Update checkpoint store dependency on eventhubs to 5.0.0 for release #9423

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
95a8ed1
Update release date
Jan 10, 2020
7412142
Add starting_position to receive samples
Jan 10, 2020
148c6a6
Add starting_position to code snippet
Jan 10, 2020
3f28dfa
Add starting_position to some code snippet
Jan 10, 2020
6f4ef51
Docstring update
Jan 11, 2020
3730459
Fix pylint error of docstring
Jan 12, 2020
af9205c
Update docstring, comment from review
Jan 13, 2020
f3f9a46
Small adjustment of docstring sample code
Jan 13, 2020
645fb69
Update dependency on eventhubs to 5.0.0
Jan 13, 2020
7676840
Merge branch 'master' into eventhubs_update_sample
Jan 13, 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
2 changes: 1 addition & 1 deletion sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/setup.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@
python_requires=">=3.5.3",
install_requires=[
'azure-storage-blob<13.0.0,>=12.0.0',
'azure-eventhub<6.0.0,>=5.0.0b6',
'azure-eventhub<6.0.0,>=5.0.0',
'aiohttp<4.0,>=3.0',
],
extras_require={
Expand Down
2 changes: 1 addition & 1 deletion sdk/eventhub/azure-eventhub-checkpointstoreblob/setup.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@
packages=find_packages(exclude=exclude_packages),
install_requires=[
'azure-storage-blob<13.0.0,>=12.0.0',
'azure-eventhub<6.0.0,>=5.0.0b6',
'azure-eventhub<6.0.0,>=5.0.0',
],
extras_require={

Expand Down
6 changes: 4 additions & 2 deletions sdk/eventhub/azure-eventhub/samples/async_samples/sample_code_eventhub_async.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -112,8 +112,9 @@ async def example_eventhub_async_send_and_receive():
logger = logging.getLogger("azure.eventhub")

async def on_event(partition_context, event):
# Put your code here.
# If the operation is i/o intensive, async will have better performance.
logger.info("Received event from partition: {}".format(partition_context.partition_id))
# Do some asynchronous ops on received event

async with consumer:
await consumer.receive(
Expand Down Expand Up @@ -171,8 +172,9 @@ async def example_eventhub_async_consumer_receive_and_close():
logger = logging.getLogger("azure.eventhub")

async def on_event(partition_context, event):
# Put your code here.
# If the operation is i/o intensive, async will have better performance.
logger.info("Received event from partition: {}".format(partition_context.partition_id))
# Do some asynchronous ops on the received event

# The receive method is a coroutine which will be blocking when awaited.
# It can be executed in an async task for non-blocking behavior, and combined with the 'close' method.
Expand Down
6 changes: 4 additions & 2 deletions sdk/eventhub/azure-eventhub/samples/sync_samples/sample_code_eventhub.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -128,8 +128,9 @@ def example_eventhub_sync_send_and_receive():
logger = logging.getLogger("azure.eventhub")

def on_event(partition_context, event):
# Put your code here.
# If the operation is i/o intensive, multi-thread will have better performance.
logger.info("Received event from partition: {}".format(partition_context.partition_id))
# Do ops on the received event

with consumer:
consumer.receive(on_event=on_event)
Expand Down Expand Up @@ -186,8 +187,9 @@ def example_eventhub_consumer_receive_and_close():
logger = logging.getLogger("azure.eventhub")

def on_event(partition_context, event):
# Put your code here.
# If the operation is i/o intensive, multi-thread will have better performance.
logger.info("Received event from partition: {}".format(partition_context.partition_id))
# Do some ops on the received event

# The 'receive' method is a blocking call, it can be executed in a thread for
# non-blocking behavior, and combined with the 'close' method.
Expand Down
2 changes: 1 addition & 1 deletion shared_requirements.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ azure-common~=1.1
azure-core<2.0.0,>=1.0.0
azure-cosmosdb-table~=1.0
azure-datalake-store~=0.0.18
azure-eventhub<6.0.0,>=5.0.0b6
azure-eventhub<6.0.0,>=5.0.0
azure-eventgrid~=1.1
azure-graphrbac~=0.40.0
azure-keyvault==4.0.0b5
Expand Down