ウェアハウス更新リファレンス¶

データベースオブジェクトとプロシージャ¶

ファイル ingestion/resource_management.sql が実行されると、以下のデータベース・オブジェクトが作成されます。

PUBLIC.UPDATE_RESOURCE(resource_ingestion_definition_id VARCHAR, ingestion_configurations VARIANT)¶

ADMIN ロールで使用可能なエントリポイントプロシージャ。このプロシージャは、Java関数 UpdateResourceHandler.updateResource を呼び出します。

PUBLIC.UPDATE_RESOURCE_VALIDATE(resource_ingestion_definition_id VARCHAR, ingestion_configurations VARIANT)¶

コネクター固有の構成の更新プロセスに使用されるプロシージャ。デフォルトでは 'response_code': 'OK' を返します。これは DefaultUpdateResourceValidator によって呼び出されます。SQL でもJavaでも上書きできます。

PUBLIC.PRE_UPDATE_RESOURCE(resource_ingestion_definition_id VARCHAR, ingestion_configurations VARIANT)¶

リソースが更新される前に呼び出されるコネクタ固有のロジックを追加するために使用されるプロシージャ。デフォルトでは 'response_code': 'OK' を返します。これは DefaultPreUpdateResourceCallback によって呼び出されます。SQL でもJavaでも上書きできます。

PUBLIC.POST_UPDATE_RESOURCE(resource_ingestion_definition_id VARCHAR, ingestion_configurations VARIANT)¶

リソースが更新された後に呼び出されるコネクター固有のロジックを追加するために使用されるプロシージャ。デフォルトでは 'response_code': 'OK' を返します。これは DefaultPostUpdateResourceCallback によって呼び出されます。SQL でもJavaでも上書きできます。

カスタムハンドラー¶

ハンドラーとその内部は、次の2つの方法を使用してカスタマイズできます。

プロシージャの代替アプローチ¶

以下のコンポーネントは SQL を使用して置き換えることができます。

ハンドラー¶

UpdateResourceHandler の全体的なカスタム実装を提供するには、 PUBLIC.UPDATE_RESOURCE プロシージャを置き換える必要があります。例:

CREATE OR REPLACE PROCEDURE PUBLIC.UPDATE_RESOURCE(resource_ingestion_definition_id VARCHAR, ingestion_configurations VARIANT)
  RETURNS VARIANT
  LANGUAGE JAVA
  RUNTIME_VERSION = '11'
  PACKAGES = ('com.snowflake:snowpark:1.11.0')
  IMPORTS = ('/connectors-native-sdk.jar')
  HANDLER = 'com.custom.handler.CustomUpdateResourceHandler.updateResource';

GRANT USAGE ON PROCEDURE PUBLIC.UPDATE_RESOURCE(VARCHAR, VARIANT) TO APPLICATION ROLE ADMIN;

内部プロシージャ¶

内部プロシージャ UPDATE_RESOURCE_VALIDATE、 PRE_UPDATE_RESOURCE 、 POST_UPDATE_RESOURCE は、 SQL を通してカスタマイズすることもできます。これらのプロシージャは、別のJavaハンドラーを呼び出すこともできます。

CREATE OR REPLACE PROCEDURE PUBLIC.UPDATE_RESOURCE_VALIDATE(resource_ingestion_definition_id VARCHAR, ingestion_configurations VARIANT)
  RETURNS VARIANT
  LANGUAGE SQL
  EXECUTE AS OWNER
  AS
  BEGIN
    -- SOME CUSTOM LOGIC BEGIN
    SELECT sysdate();
    -- SOME CUSTOM LOGIC END

    RETURN OBJECT_CONSTRUCT('response_code', 'OK');
  END;

CREATE OR REPLACE PROCEDURE PUBLIC.UPDATE_RESOURCE_VALIDATE(resource_ingestion_definition_id VARCHAR, ingestion_configurations VARIANT)
  RETURNS VARIANT
  LANGUAGE JAVA
  RUNTIME_VERSION = '11'
  PACKAGES = ('com.snowflake:snowpark:1.11.0')
  IMPORTS = ('/connectors-native-sdk.jar')
  HANDLER = 'com.custom.handler.CustomHandler.updateResourceValidate';

ビルダーアプローチ¶

UpdateResourceHandler は、 UpdateResourceHandlerBuilder を使用してカスタマイズできます。このビルダーを使用すると、ユーザーは次のインターフェイスのカスタム実装を提供できます。

UpdateResourceValidator
PreUpdateResourceCallback
PostUpdateResourceCallback
ConnectorErrorHelper

関数が提供されていない場合は、 SDK によって提供されるデフォルトの実装が使用されます。

class CustomPreUpdateResourceCallback implements PreUpdateResourceCallback {
  @Override
  public ConnectorResponse execute(String resourceIngestionDefinitionId, Variant updatedIngestionConfigurations) {
    // CUSTOM LOGIC
    return ConnectorResponse.success();
  }
}

class CustomHandler {

  // Path to this method needs to be specified in the PUBLIC.UPDATE_RESOURCE procedure using SQL
  public static Variant updateResource(Session session, String resourceIngestionDefinitionId, Variant updatedIngestionConfigurations) {
    //Using builder
    var handler = UpdateResourceHandlerBuilder.builder(session)
      .withPreUpdateResourceCallback(new CustomPreUpdateResourceCallback())
      .build();
    return handler.updateResource(resourceIngestionDefinitionId).toVariant();
  }
}