從磚導入sql主機名= ' .www.eheci.com <名稱> ' http_path = ' / sql / 1.0 /端點/ < endpoint_id > access_token = = < personal_token >的連接sql。連接(server_hostname =主機名、http_path = http_path access_token = access_token)光標= connection.cursor () cursor.execute (test_query)結果= cursor.fetchall行()的結果:打印(行)cursor.close ()
我得到以下錯誤當我在筆記本上麵的代碼執行。
我有權限使用和access_token入口點。我已經刪除了他們的問題!
在OpenSession錯誤;要求:TOpenSessionReq (client_protocol = 5,用戶名=沒有密碼=沒有配置= None)錯誤:沒有Bounded-Retry-Delay:沒有嚐試:1/30 Elapsed-Seconds: 1.3954582214355469/900.0 - - - - - > = 7連接sql。連接(server_hostname =主機名、8 http_path = http_path 9 access_token = access_token) /磚/ python / lib / python3.8 /網站/磚/ sql / __init__。py在連接(server_hostname http_path access_token, * * kwargs) 26日”““從databricks.sql 27。客戶端導入連接- - - > 28日返回連接(server_hostname、http_path access_token, * * kwargs) /磚/ python / lib / python3.8 /網站/磚/ sql /客戶端。py __init__(自我、server_hostname http_path access_token, * * kwargs) 261 client_protocol = protocol_version 262) - - > 263 = self._make_request (self._client響應。OpenSession open_session_req) 264年_check_status(響應)265斷言響應。sessionHandle不是沒有,“從OpenSession預期一個會話”/磚/ python / lib / python3.8 /網站/磚/ sql /客戶端。py _make_request(自我,方法,請求)372年或運行+ retry_delay > self._retry_stop_after_attempts_duration): 373 _logger。錯誤(誤差在+ log_base) - - > 374年籌集OperationalError(“節儉請求期間錯誤”+ 375 (“:”+ error_message)如果其他error_message ", 376錯誤)OperationalError: (“EOFError ())
嗨@Borislav Blagoev,
非常感謝你花時間來收集這些日誌。
這裏的問題(“IpAclValidation”顯示的消息)是IP允許清單(支持工作區)將不允許任意連接從火花集群回到默認的控製層麵。數據平麵的子網(s)需要被添加到IP允許列表。
這裏是一個鏈接到文檔IpACL驗證:https://docs.www.eheci.com/security/network/ip-access-list.html
這裏是一個鏈接到文檔管理子網的數據平麵:https://docs.www.eheci.com/administration-guide/cloud-configurations/aws/customer-managed-vpc.html…
不確定你的最終目標是什麼,但它也可能是值得一提的,(更好的)替代磚上使用“databricks-sql-connector”筆記本。例如,在一個Python筆記本你可以使用“spark.sql(…)”執行的SQL命令。
聽起來太棒了!謝謝你!
謝謝你!