カスタムアクションSDK
プロジェクト内で実行されるコードからプロジェクトデータを読み書きします。
SDKの用途
カスタムアクションSDKは、プロジェクト内部からプロジェクトとやり取りするために使用されるPythonライブラリです。カスタムアクション、カスタムPySparkアクション、および統合Jupyterノートブックで利用可能です。そのため、ノートブックでコードを書いてテストした後、変更せずにアクションに貼り付けることができます。ある関数がそのようなコンテキストのいずれかで利用できない場合は、その関数のページに記載されています。
クイックスタート
4つの短いチュートリアルがあります。それぞれのターゲット向けです:データセットの読み取り、バケットの読み取り、登録済みソースの読み取り、および同じ読み取りのPySparkバリエーションです。それぞれが完全なアクションで、貼り付けて実行できます。SDKを初めて使用する場合は、最初に確認する自然な場所です。
プロジェクトデータに接続
エントリポイントはconnect()で、接続文字列を受け取り、その文字列が指すもののコネクタを返します:データセット、テーブル、バケット、または登録済みソースです。返されるオブジェクトはターゲットによって異なるため、コネクタガイドではそれぞれを個別にカバーしています。bulk_insert()は、書き込み用のカウンターパートで、pandasデータフレームをバッチ単位で目的地のテーブルに取り込みます。
PySparkは、同じコネクタオブジェクト上のSpark互換メソッドを通じて処理されます。そのため、PySparkアクションは、pandasデータフレームではなくSparkデータフレームとしてテーブルを読み取ります。SDKリファレンスにはすべてのシグネチャが記載されています。
高度な機能
これらのガイドでは、アクションを本番環境で利用可能にするための内容をカバーしています:ハードコードされた値の代わりに環境変数を使用する、セグメンテーションにより1つのアクションを並列タスクに分割する、Loadアクションをオーバーライドする、GitからカスタムPythonモジュールをインポートする、およびラインナージイベントを発行する方法です。
コードサンプルはまだforepaas.*からインポートしています。これらのモジュール名はプラットフォーム上で今日変更されていません。SDKのリネームがリリースされた際にサンプルが更新されます。
クイックスタート: データセット→
プロジェクトテーブルに対する最初のスクリプト。
クイックスタート: バケット→
プロジェクトバケットに対する最初のスクリプト。
クイックスタート: ソース→
登録済みソースに対する最初のスクリプト。
クイックスタート: PySpark→
最初のPySparkスクリプト。
コネクタと接続文字列→
各接続文字列オプションと、それぞれが返す内容。
SDKリファレンス: 接続と一括挿入→
2つのエントリーポイント関数と、一括挿入の署名。
データの系譜を追跡→
カスタムコードとノートブックからの系譜を発行。
さらに深く掘り下げる
当社のソリューションを実装するためのトレーニングや技術サポートが必要な場合は、営業担当者にお問い合わせください、またはこのリンクをクリックして、当社のプロフェッショナルサービスの専門家にプロジェクトのカスタム分析を依頼する見積もりを取得してください。
Data Platformを構築するチームと直接質問をし、フィードバックを提供し、Discordチャネルで交流する専用Discordチャネル。
OVHcloudサービスについてサポートが必要な場合は、ヘルプセンターでリクエストを作成してください。
ユーザーコミュニティに参加してください。

