用Python连接到Oracle AQ

Question

我正在尝试使用Python连接到Oracle高级队列。

我要做的基本原则是:已经建立了一个队列，它每小时发送一次消息，我想对这条消息进行处理，并使用我编写的一些代码来分析它。

我有凭据(主机、端口、sid、用户和密码)，但我不知道如何设置连接并开始使用。

从我以前在网上的问题中可以了解到，cx_oracle模块应该具有这样的能力，但我无法在实践中找到如何做到这一点。

如果您有任何教程的链接，说明如何做到这一点，或者如果您自己有一些示例代码，这将是非常感谢的。我有一些关于RabbitMQ队列的经验，但是似乎关于Oracle的例子和教程不多，因此我在这里提出问题。

Answer 1

cx_Oracle高级队列文档是这里。

例如：

# setup connection
connection = cx_Oracle.Connection('connection string')  

# get the options
options = connection.deqoptions()  

# set relevant options:
options.navigation = cx_Oracle.DEQ_FIRST_MSG
options.wait = cx_Oracle.DEQ_WAIT_FOREVER

# continuously deque    
while connection.deq(NAME_OF_QUEUE, options, messageProperties, payload):
    print(payload)

Anthony Tuininga (cx_Oracle作者)在Github上有一个更完整的例子。