PythonでOracle AQに接続

Question

Pythonを使用してOracleの高度なキューに接続しようとしています。

私がしようとしている基本的な原則は次のとおりです。1時間に1回メッセージを送信するキューが設定されました。このメッセージを非表示にして、私が書いたコードで分析します。

私は資格情報（ホスト、ポート、sid、ユーザ& passwn）を持っていますが、接続を設定して消費する方法がわかりません。

ウェブ上のこれまでの質問からわかるように、cx_oracleモジュールにはこれを実行する機能が必要ですが、実際にこれを行う方法を理解することはできません。

これがどのように行われたかを示すチュートリアルへのリンクがある場合、またはサンプルコードを自分で持っている場合は、非常に感謝します。私はRabbitMQキューを試してみましたが、Oracle AQのサンプルとチュートリアルが少なくてすみますので、ここで私の質問です。

Answer 1

cx_Oracleアドバンストキューイングのドキュメントはhereです。

の例では、のようになります。

# 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) 

アンソニーTuininga（cx_Oracleの作者）がGithubにはるかに完全な例があります。