メインコンテンツまでスキップ

ジョブ用Pythonスクリプトタスク

Pythonスクリプト タスクを使用して、Pythonファイルを実行します。

要件

  • Pythonスクリプトは、ジョブを構成するユーザーがアクセスできる場所にアップロードする必要があります。Databricksでは、Pythonスクリプトにワークスペースファイルを使用することをお勧めします。ワークスペースファイルとは何ですか?

Pythonスクリプトタスクを構成する

注記

ジョブUIは、他の構成された設定に基づいてオプションを動的に表示します。

Databricksでは、DBFSルートまたはマウントを使用してコードやデータを保存することを推奨していません。代わりに、Pythonスクリプトをワークスペースファイルまたはボリュームに移行するか、URIを使用してクラウドオブジェクトストレージにアクセスできます。

Python scriptタスクの設定を開始する手順。

  1. ジョブUIの タスク タブに移動します。
  2. プラスアイコン。 タスクを追加 をクリックします。
  3. 「タスク名」 フィールドに名前を入力します。
  4. タイプ ドロップダウンメニューで、Python scriptを選択します。

ソースを構成

ソース ドロップダウン メニューで、次のいずれかのオプションを使用して Python スクリプトの場所を選択します。

workspace

ワークスペース ファイルを使用して格納されたPythonスクリプトを構成するには、 ワークスペース を使用します。

  1. パス フィールドをクリックします。 Python ファイルの選択 ダイアログが表示されます。
  2. Python スクリプトを参照し、ファイルをクリックしてハイライト表示し、 確認 をクリックします。
注記

このオプションを使用すると、Databricks Git フォルダーに保存されている Python スクリプトでタスクを構成できます。Databricks では、ジョブでスケジュールされるアセットのバージョン管理に Git provider オプションとリモート Git リポジトリを使用することを推奨しています。

DBFS/GCS

DBFS/GCS を使用して、ボリューム、クラウド オブジェクト ストレージの場所、またはDBFS ルートに格納されているPythonスクリプトを構成します。

Databricksでは、PythonスクリプトをUnity Catalogボリュームまたはクラウドオブジェクトストレージに保存することをお勧めします。

パス フィールドに、Python スクリプトの URI を入力します。たとえば、 dbfs:/path/to/script.pygs://bucket-name/path/to/script.pyなどです。

Git プロバイダー

**「Git プロバイダー」**を使用して、リモート Git リポジトリに格納されている Python スクリプトを構成します。

UI に表示されるオプションは、他の場所で Git プロバイダーをすでに構成しているかどうかに応じて異なります。ジョブ内のすべてのタスクには、リモート Git リポジトリは 1 つのみ使用できます。LakeFlow ジョブで Git を使用するを参照してください。

パス フィールドは、git 参照を設定した後に表示されます。

Pythonスクリプトの相対パスを入力します。たとえば、etl/bronze/ingest.pyのように。

重要

相対パスを入力するときは、/または./で開始しないでください。例えば、アクセスしたいPythonコードの絶対パスが/etl/bronze/ingest.pyの場合、 パス フィールドにetl/bronze/ingest.pyを入力します。

コンピュートと依存ライブラリの構成

  1. コンピュート を使用して、スクリプト内のロジックをサポートするクラスターを選択または構成します。
  2. プラスアイコン。 依存ライブラリ の下にある 追加 をクリックします。 依存ライブラリの追加 ダイアログが表示されます。
    • 既存のライブラリを選択するか、新しいライブラリをアップロードできます。
    • コンピュート構成でサポートされている場所に保存されているライブラリのみ使用できます。Python ライブラリのサポートを参照してください。
    • ライブラリ ソース には、ライブラリを選択またはアップロードするための異なるフローがあります。ライブラリのインストールを参照してください。

ジョブ構成を確定する

  1. (オプション)PythonスクリプトにCLIの引数として渡される文字列のリストとして パラメーター 構成します。タスク パラメーターの設定を参照してください。
  2. (オプション)再試行、実行時間またはストリーミングバックログしきい値、または通知を構成するには、「高度なタスク設定」を参照してください。
  3. タスクの保存 をクリックします。

このタスクを編集、複製、無効化、または削除するには、「Lakeflowジョブでタスクを構成および編集する」を参照してください。