使用AMQP从Azure Eventhub接收事件

Question

目标：使用python从EventHub接收消息。

设置:

• Python 3.5
• AMQP 1.0
• 在新门户中创建的EventHub。
• Ubuntu 16.04和Mac OS X。
• 质子==0.8.8和python-qpid-质子==0.17.0

几天来，我一直在尝试连接AMQP和Azure EventHub。我可以用Java客户端很好地做到这一点(作为确保EventHub工作的测试),但我需要能够用Python做到这一点。

在网上阅读了几个例子后，我在过去几天尝试了很多事情。我正在使用＜code＞RootManageSharedAccessKey以及正常报价。

目前我的字符串如下所示：

am qp s：//根管理共享访问密钥：

如果我将这些相同的参数复制到Java客户机中，它就可以正常工作。如果我使用python SDK发送，它也可以正常工作（它通过HTTPS发送）。我尝试过使用amqp和amqp如果我为amqp打开调试参数，我会得到错误：

condition=:"amqp:unauthorized-access",
description="Unauthorized access. 'Send' claim(s) are required to perform this operation.
Resource: 'sb://<namespace>.servicebus.windows.net/<internal event hub>

这听起来是一个权限问题，但相同的密钥和所有内容在Java和Python中都可以通过HTTPS完美运行，因此它必须是我的代码与密钥中的内容。也许我没有正确编码它们（我已经读过你不需要编码它们）？一旦我让它工作，我将为其他人制作GIST和更新。

我的当前代码如下发送应该更容易：

from proton import Messenger, Message

messenger = Messenger()
message = Message()
key = "key"
message.address = "amqps://RootManageSharedAccessKey:"+key+"@<namespace>.servicebus.windows.net/<hubname>"

message.body = u"This is a text string"
messenger.put(message)
messenger.send()`

我尝试过的事情：

1. 使事件中心和命名空间上的发送和接收策略分开。
2. 重新创建集线器
3. 安全与不安全
4. 将端口添加到防火墙
5. Python 2.7质子vs 3.5
6. Linuxvs Mac
7. 主键vs副键
8. 新命名空间
9. 键中有和没有/的新密钥
10. URL编码部分和整个字符串
11. UTF-8编码
12. JSON消息与短信。




Answer 1

这对您的项目来说可能太晚了，但是这里有一个新的用于Python的AMQP 1.0库正在开发中：

http://github.com/Azure/azure-uamqp-python

尽管它仍处于早期阶段(尚未准备好生产)，但repo中有一些用于Azure事件中心的示例:

https://github.com/Azure/azure-uamqp-python/tree/master/samples

关于您在使用Proton时看到的错误-看起来它可能试图使用错误的身份验证机制。您尝试过使用事件中心Python SDK吗？他们在这里使用了一些可能感兴趣的设置