azureeventhubreceiveevent

Azure Event Hub receive event Python example

This folder contains a Python application example that handles Event Hubs on Microsoft Azure.

It handles an Event Hub and receive events from an event hub event stream.

Requirements

• You must have a Microsoft Azure subscription.

• You must have the following installed:

  • Python 3
  • Azure CLI

• The code was written for:

  • Python 3
  • Azure SDK for Python: New Client Libraries (Azure Event Hub library v5)

• You install individual Azure library packages on a per-project basis depending on your needs. It is recommended using Python virtual environments for each project. There is no standalone "SDK" installer for Python.

• Install the specified python packages.

  pip install -r requirements.txt

Using the code

• Sign in Azure (Interactively).

  The Azure CLI's default authentication method for logins uses a web browser and access token to sign in.

  1. Run the Azure CLI login command.

     az login

     If the CLI can open your default browser, it will do so and load an Azure sign-in page.

     Otherwise, open a browser page at https://aka.ms/devicelogin and enter the authorization code displayed in your terminal.

     If no web browser is available or the web browser fails to open, use device code flow with az login --use-device-code.

  2. Sign in with your account credentials in the browser.

  Make sure you select your subscription by:

  az account set --subscription <name or id>

• Create an Event Hubs Namespace and an Event Hub.

  1. Create an Event Hubs Namespace.

     An Event Hubs namespace provides a unique scoping container, in which you create one or more event hubs.

     To create a namespace in your resource group using the portal, do the following actions:

     1. You must create the Event Hubs Namespace, using the Azure console.

     2. Select the your data for: Suscription, Resource group, Namespace name and Location.

     3. Choose Basic for the pricing tier.

  2. Create an Event Hub.

     You must create the Event Hub, using the Azure console.

     To create an event hub within the namespace, do the following actions:

     1. On the Event Hubs Namespace page, select Event Hubs in the left menu.

     2. At the top of the window, select + Event Hub.

     3. Type a name for your event hub, then select Create.

  3. Create a SAS Policy.

     You must create the SAS Policy, using the Azure console.

     1. On the Event Hubs page for the Event Hub created, select Shared access policies in the left menu.

     2. At the top of the window, select + Add.

     3. Type a name for your Policy, select Manage, that includes Send and Listen, then select Create.

• Create an Azure storage account and a blob container.

  Create an Azure storage account and a blob container in it by doing the following steps, using the Azure console:

  1. Create an Azure Storage account.

  2. Create a blob container.

  3. Get the connection string to the storage account.

• Configure your application.

  We store the configuration information in a config file (app.cfg). The file content is:

  [Configuration]
  StorageAccountConnectionString=<STORAGE_ACCOUNT_CONNECTION_STRING>
  BlobName=<BLOB_NAME>
  EventHubConnectionString=<EVENT_HUB_CONNECTION_STRING>
  EventHubName=<EVENT_HUB_NAME>

  You only need to edit the file app.cfg and modify the values of:

  • <STORAGE_ACCOUNT_CONNECTION_STRING> by the Connection string to the Storage Account.
  • <BLOB_NAME> by the Blob name in the Storage Account.
  • <EVENT_HUB_CONNECTION_STRING> by the Connection string to the Event Hub.
  • <EVENT_HUB_NAME> by the name of the Event Hub.

  The application uses this information for accessing your Event Hub and Storage Account.

• Run the code.

  Execute the receiver application:

  python receivereh.py

  You should see the next message in you receiver application:

  Waiting for an event

  The application is waiting for some event from the Event Hub.

• Test the application.

  You must send an event to your Event Hub.

  You can use the Python application sendereh.py (Event Hub send event). You can get it following this link: ../azureeventhubsendevent/

  In another command line console, execute the sender application:

  python sendereh.py

  You should see the next message in your sender application:

  Preparing batch of events
  Sending batch of events
  Sent

  When the receiver application gets the event, you should see the next message in you receiver application:

  Received the event: "<XXXXXXXXXXXXXXX>"
    from the partition with ID: <X>
    EnqueuedTimeUtc: <YYYY-MM-DD HH:MM:SS.XXXXXXXXX>
    SequenceNumber: <XX>
    Offset: <XXXX>