Habilitação de referência de recurso¶

Objetos e procedimentos de banco de dados¶

Os seguintes objetos de banco de dados são criados quando o arquivo ingestion/resource_management.sql é executado.

PUBLIC.ENABLE_RESOURCE(resource_ingestion_definition_id VARCHAR)¶

Procedimento de ponto de entrada disponível para a função ADMIN. Este procedimento invoca a função Java EnableResourceHandler.enableResource.

PUBLIC.ENABLE_RESOURCE_VALIDATE(resource_ingestion_definition_id VARCHAR)¶

Procedimento usado para validação específica do conector do processo de ativação. Por padrão, ela retorna 'response_code': 'OK'. É invocado por DefaultEnableResourceValidator. Pode ser sobrescrito em ambos SQL e Java.

PUBLIC.PRE_ENABLE_RESOURCE(resource_ingestion_definition_id VARCHAR)¶

Procedimento usado para adicionar lógica específica do conector invocada antes de um recurso ser habilitado. Por padrão, ela retorna 'response_code': 'OK'. É invocado por DefaultPreEnableResourceCallback. Pode ser sobrescrito em ambos SQL e Java.

PUBLIC.POST_ENABLE_RESOURCE(resource_ingestion_definition_id VARCHAR)¶

Procedimento usado para adicionar lógica específica do conector invocada depois que um recurso é habilitado. Por padrão, ela retorna 'response_code': 'OK'. É invocado por DefaultPostEnableResourceCallback. Pode ser sobrescrito em ambos SQL e Java.

Manipulador personalizado¶

O manipulador e seus componentes internos podem ser personalizados usando as seguintes abordagens.

Abordagem de substituição de procedimento¶

Os seguintes componentes podem ser substituídos usando SQL.

Manipulador¶

Para fornecer implementação personalizada completa de EnableResourceHandler, o procedimento PUBLIC.ENABLE_RESOURCE deve ser substituído. Por exemplo:

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

  GRANT USAGE ON PROCEDURE PUBLIC.ENABLE_RESOURCE(VARCHAR) TO APPLICATION ROLE ADMIN;

Procedimentos internos¶

Os procedimentos internos ENABLE_RESOURCE_VALIDATE, PRE_ENABLE_RESOURCE e POST_ENABLE_RESOURCE também podem ser personalizados através de SQL. Esses procedimentos também podem invocar outros manipuladores Java:

CREATE OR REPLACE PROCEDURE PUBLIC.ENABLE_RESOURCE_VALIDATE(resource_ingestion_definition_id VARCHAR)
  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.ENABLE_RESOURCE_VALIDATE(resource_ingestion_definition_id VARCHAR)
  RETURNS VARIANT
  LANGUAGE JAVA
  RUNTIME_VERSION = '11'
  PACKAGES = ('com.snowflake:snowpark:1.11.0')
  IMPORTS = ('/connectors-native-sdk.jar')
  HANDLER = 'com.custom.handler.CustomHandler.enableResourceValidate';

Abordagem do construtor¶

EnableResourceHandler pode ser personalizado usando EnableResourceHandlerBuilder. Este construtor permite que o usuário forneça implementações personalizadas das seguintes interfaces:

EnableResourceValidator
PreEnableResourceCallback
PostEnableResourceCallback
ConnectorErrorHelper

Caso uma função não seja fornecida, a implementação padrão fornecida pelo SDK será usada.

class CustomPreEnableResourceCallback implements PreEnableResourceCallback {
  @Override
  public ConnectorResponse execute(String resourceIngestionDefinitionId) {
    // CUSTOM LOGIC
    return ConnectorResponse.success();
  }
}

class CustomHandler {

  // Path to this method needs to be specified in the PUBLIC.ENABLE_RESOURCE procedure using SQL
  public static Variant enableResource(Session session, String resourceIngestionDefinitionId) {
    //Using builder
    var handler = EnableResourceHandlerBuilder.builder(session)
      .withPreEnableResourceCallback(new CustomPreEnableResourceCallback())
      .build();
    return handler.enableResource(resourceIngestionDefinitionId).toVariant();
  }
}