Send messages to an Azure Event Hub using the Apache Qpid Proton AMQP library.

event_hubs_send.py

#!/usr/bin/python

# Send messages to an Azure Event Hub using the Apache Qpid Proton AMQP library.

import sys
import commands
from proton import *

# Event Hub address & credentials
# amqps://<keyname>:<key>@<namespace>.servicebus.windows.net/<eventhubname>
# You can find <keyname> and <key> in your Service Bus connection information
# <key> needs to be URL-encoded
# <namespace> is your SB top-level namespace
# <eventhubname> is the name of your Event Hub

address = "amqps://send:xxxx@demohub.servicebus.windows.net/yun";

# Create Proton objects
messenger = Messenger()

# Create AMQP message
message = Message()

message.body = sys.argv[1]

message.address = address
messenger.put(message)
messenger.send()