CData Python Connector for Spark SQL

Build 23.0.8839

接続の確立

コネクタ内で利用可能なオブジェクトは、"cdata.sparksql" モジュールからアクセスできます。モジュールのオブジェクトを直接使用するには:

  1. モジュールを以下のようにインポートします。
    import cdata.sparksql as mod
  2. 接続を確立するには、以下のような適切な接続文字列を使用してコネクタオブジェクトからconnect() メソッドを呼び出します。
    mod.connect("Server=127.0.0.1;")

Spark SQL への接続

Spark SQL への接続を確立するには以下を指定します。

  • Server:SparkSQL をホストしているサーバーのホスト名、またはIP アドレス。
  • Port:SparkSQL インスタンスへの接続用のポート。
  • TransportMode:SparkSQL サーバーとの通信に使用するトランスポートモード。有効な入力値は、BINARY およびHTTP です。デフォルトではBINARY が選択されます。

セキュアなSpark SQL への接続

本製品 においてTLS/SSL を有効化するには、UseSSL をTrue に設定します。

Spark SQL への認証

サービスは、PLAIN、LDAP、NOSASL、KERBEROS 認証スキームを使用して認証できます。

PLAIN

PLAIN で認証するには、次の接続プロパティを設定します。

  • AuthSchemePLAIN
  • User:ログインするユーザー。
  • Password:ユーザーのパスワード。
認証するには、User およびPassword を設定します。

LDAP

LDAP で認証するには、次の接続プロパティを設定します。

  • AuthSchemeLDAP
  • User:ログインするユーザー。
  • Password:ユーザーのパスワード。
認証するには、UserPassword、およびAuthScheme を設定します。

NOSASL

NOSASL を使用する場合、認証は行われません。次の接続プロパティを設定します。

  • AuthSchemeNOSASL

Kerberos

Kerberos で認証する方法についての詳細は、Kerberos の使用 を参照してください。

Copyright (c) 2024 CData Software, Inc. - All rights reserved.
Build 23.0.8839