Python経由でQuboleに接続するのは初めてです。
この例に従って、jaydebeapi を直接使用して接続できます:この例ですが、 pypiまたはquboleの指示に従ってsqlalchemy-qubole を使用すると、パスワード キーが見つからないというエラーが表示されます。APIキーを接続文字列に直接埋め込んでみましたが、同じエラーが発生したため、接続文字列の形成方法とは関係ないと思います。
コード:
engine = create_engine('qubole+presto://presto/presto_cluster?endpoint=https://us.qubole.com;password=' +
api_key + ';catalog_name=hive')
with engine.connect() as con:
rs = con.execute('SHOW TABLES')
エラーメッセージ:
*(stacktrace excluded)*
java.sql.SQLNonTransientConnectionExceptionPyRaisable: java.sql.SQLNonTransientConnectionException: [Qubole][JDBC](10100) Connection Refused: [Qubole][JDBC](11640) Required Connection Key(s): password