スキルOfficialdevelopment
🗄️aidp-sqlserver
- ソース
- GitHub で見る ↗
説明
AIDPの `aidataplatform` Spark フォーマットハンドラーを介して、AIDPノートブックからMicrosoft SQL Serverの読み取りまたは書き込みを行います。 次のような場合に使用: ユーザーがSQL Server、MSSQL、Azure SQL Databaseに言及している場合、またはTDSのホスト/ポートを持っている場合。 認証情報: ホスト/ポート + データベース名 + ユーザー名/パスワード。
原文を表示
Read or write Microsoft SQL Server from an AIDP notebook via the AIDP `aidataplatform` Spark format handler. Use when the user mentions SQL Server, MSSQL, Azure SQL Database, or has a TDS host/port. Auth is host/port + database + user/password.
ユースケース
- ✓SQL Serverのデータを読み取るとき
- ✓SQL Serverへデータを書き込むとき
- ✓Azure SQL Databaseを操作するとき
- ✓TDSプロトコルでDBに接続するとき
本文(日本語訳)
aidp-sqlserver — AIDP aidataplatform 経由の Microsoft SQL Server
次のような場合に使用
- AIDPノートブックから Microsoft SQL Server(または Azure SQL Database)の読み取り・書き込みを行う場合。
- 次のキーワードが含まれる場合: "SQL Server"、"MSSQL"、"Azure SQL"、"TDS"
次のような場合は使用しない
- Postgres の場合 →
aidp-postgresql - MySQL の場合 →
aidp-mysql
読み取り(Read)
import os
from oracle_ai_data_platform_connectors.aidataplatform import (
AIDP_FORMAT, aidataplatform_options,
)
opts = aidataplatform_options(
type="SQLSERVER",
host=os.environ["MSSQL_HOST"],
port=int(os.environ.get("MSSQL_PORT", "1433")),
user=os.environ["MSSQL_USER"],
password=os.environ["MSSQL_PASSWORD"],
schema=os.environ.get("MSSQL_SCHEMA", "dbo"),
table=os.environ["MSSQL_TABLE"],
)
df = spark.read.format(AIDP_FORMAT).options(**opts).load()
df.show(5)
書き込み(Write)
opts = aidataplatform_options(
type="SQLSERVER",
host=os.environ["MSSQL_HOST"],
port=int(os.environ.get("MSSQL_PORT", "1433")),
database_name=os.environ["MSSQL_DATABASE"], # 書き込み時は必須
user=os.environ["MSSQL_USER"],
password=os.environ["MSSQL_PASSWORD"],
schema=os.environ.get("MSSQL_SCHEMA", "dbo"),
table=os.environ["MSSQL_TARGET_TABLE"],
extra={"write.mode": "CREATE"},
)
df.write.format(AIDP_FORMAT).options(**opts).save()
注意事項(Gotchas)
database.nameは書き込み時に必須ですが、読み取り時は必須ではありません。 読み取りで "object not found" エラーが発生した場合は、database_name=も指定してください。 SQL Server の構成によっては、コネクタが名前解決を行うために必要となる場合があります。- スキーマとデータベースの違い: SQL Server にはどちらも存在します。
ここでの
schemaは SQL Server スキーマ(通常はdbo)を指し、database.nameはカタログ(例:master、AdventureWorks)を指します。 - TDS ポートはデフォルトで 1433 です。 Azure SQL Database はパブリック TLS 経由でポート 1433 を公開しており、 AIDP はエグレスルートを通じてそこへ到達できる必要があります。
- Azure SQL は同じ
SQLSERVERタイプを使用します。 完全修飾ホスト名(<srv>.database.windows.net)と SQL 認証ユーザーを使用してください (Active Directory は不可。AIDP は AAD トークンの仲介を行いません)。
参考資料
原文(English)を表示
aidp-sqlserver — Microsoft SQL Server via AIDP aidataplatform
When to use
- Read or write a Microsoft SQL Server (or Azure SQL Database) from an AIDP notebook.
- Mentioned: "SQL Server", "MSSQL", "Azure SQL", "TDS".
When NOT to use
- For Postgres →
aidp-postgresql. - For MySQL →
aidp-mysql.
Read
import os
from oracle_ai_data_platform_connectors.aidataplatform import (
AIDP_FORMAT, aidataplatform_options,
)
opts = aidataplatform_options(
type="SQLSERVER",
host=os.environ["MSSQL_HOST"],
port=int(os.environ.get("MSSQL_PORT", "1433")),
user=os.environ["MSSQL_USER"],
password=os.environ["MSSQL_PASSWORD"],
schema=os.environ.get("MSSQL_SCHEMA", "dbo"),
table=os.environ["MSSQL_TABLE"],
)
df = spark.read.format(AIDP_FORMAT).options(**opts).load()
df.show(5)
Write
opts = aidataplatform_options(
type="SQLSERVER",
host=os.environ["MSSQL_HOST"],
port=int(os.environ.get("MSSQL_PORT", "1433")),
database_name=os.environ["MSSQL_DATABASE"], # required on write
user=os.environ["MSSQL_USER"],
password=os.environ["MSSQL_PASSWORD"],
schema=os.environ.get("MSSQL_SCHEMA", "dbo"),
table=os.environ["MSSQL_TARGET_TABLE"],
extra={"write.mode": "CREATE"},
)
df.write.format(AIDP_FORMAT).options(**opts).save()
Gotchas
database.nameis required on write but not strictly on read. If a read fails with "object not found", supplydatabase_name=too — some SQL Server installs require it for the connector to disambiguate.- Schema vs database: SQL Server has both.
schemahere is the SQL-Server schema (typicallydbo);database.nameis the catalog (e.g.master,AdventureWorks). - TDS port 1433 by default. Azure SQL Database exposes port 1433 over public TLS; AIDP must reach it via its egress route.
- Azure SQL uses the same
SQLSERVERtype. Use the fully-qualified host (<srv>.database.windows.net) and the SQL-auth user (NOT Active Directory; AIDP doesn't broker AAD tokens).
References
原文・著作権は Anthropic および各プラグイン作者に帰属します。日本語訳は Claude API による自動翻訳です。