MaxCompute:スキーマ

ランタイム環境を準備する

基本操作を実行する

MaxCompute のスキーマ機能を使用する場合は、スキーマ関連の操作で有効にすることができます。

• スキーマを作成します。

  schema = o.create_schema("**schema_name**")
  print(schema)

• スキーマを削除します。

  schema = o.delete_schema("**schema_name**")

• すべてのスキーマを一覧表示します。

  for schema in o.list_schemas():
      print(schema)

• スキーマ機能を有効にすると、MaxCompute エントリオブジェクトが操作を実行できるすべての MaxCompute オブジェクトは、DEFAULT という名前のスキーマに配置されます。 他のスキーマ内のオブジェクトに対して操作を実行するには、エントリオブジェクトを作成するときにスキーマを指定する必要があります。 サンプルコード:

  # 環境変数 ALIBABA_CLOUD_ACCESS_KEY_ID を AccessKey ID に設定します。
  # 環境変数 ALIBABA_CLOUD_ACCESS_KEY_SECRET を AccessKey シークレットに設定します。
  # AccessKey ID または AccessKey シークレットを直接使用しないことをお勧めします。
  o = ODPS(
      os.getenv('ALIBABA_CLOUD_ACCESS_KEY_ID'),
      os.getenv('ALIBABA_CLOUD_ACCESS_KEY_SECRET'),
      project='<your-default-project>',
      endpoint='<your-end-point>',
      schema='<your-schema-name>',
  )

  次の表にパラメーターを示します。

  パラメーター	説明
  your-default-project	MaxCompute プロジェクトの名前。
  your-end-point	MaxCompute プロジェクトのエンドポイント。 MaxCompute プロジェクトの作成時に選択したリージョンとネットワーク接続方法に基づいて、このパラメーターを設定する必要があります。 各リージョンとネットワークに対応するエンドポイントの詳細については、「エンドポイント」をご参照ください。 重要 無効なエンドポイントを指定すると、MaxCompute にアクセスしたときにエラーが発生します。
  your-schema-name	スキーマの名前。

• さまざまなオブジェクトの操作メソッドに schema パラメーターを指定します。 サンプルコード:

  # test_schema テーブル内のすべてのテーブルを一覧表示します。
  for table in o.list_tables(schema='**schema_name**'):
      print(table)

• SQL 文を実行するときにデフォルトのスキーマを指定します。 サンプルコード:

  o.execute_sql("SELECT * FROM dual", default_schema="**schema_name**")