Referência do conector de pausa

Objetos e procedimentos de banco de dados

Os seguintes objetos de banco de dados são criados por meio do arquivo lifecycle/pause.sql.

PUBLIC.PAUSE_CONNECTOR()

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

PUBLIC.PAUSE_CONNECTOR_VALIDATE()

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

PUBLIC.PAUSE_CONNECTOR_INTERNAL()

Procedimento usado para tarefas de pausa adicionais específicas do conector. Por padrão, ela retorna 'response_code': 'OK'. É invocado por InternalPauseConnectorCallback. Pode ser sobrescrito em ambos SQL e Java.

Manipulador personalizado

O manipulador e seus componentes internos podem ser personalizados usando as duas abordagens a seguir.

Abordagem de substituição de procedimento

Os seguintes componentes podem ser substituídos usando SQL.

Manipulador

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

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

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

Procedimentos internos

Os procedimentos internos VALIDATE e INTERNAL também podem ser personalizados através do SQL. Eles também podem invocar outro manipulador Java:

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

Abordagem do construtor

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

  • PauseConnectorStateValidator

  • PauseConnectorCallback

  • ConnectorErrorHelper

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

class CustomPauseConnectorStateValidator implements PauseConnectorStateValidator {
    @Override
    public ConnectorResponse validate() {
        // CUSTOM LOGIC
        return ConnectorResponse.success();
    }
}

class CustomHandler {

    // Path to this method needs to be specified in the PUBLIC.PAUSE_CONNECTOR procedure using SQL
    public static Variant pauseConnector(Session session) {
            //Using builder
        var handler = PauseConnectorHandlerBuilder.builder(session)
            .withStateValidator(new CustomPauseConnectorStateValidator())
            .build();
        return handler.pauseConnector().toVariant();
    }
}