コネクタを再開リファレンス¶
データベースオブジェクトとプロシージャ¶
次のデータベースオブジェクトは、ファイル lifecycle/resume.sql
を通して作成されます。
PUBLIC.RESUME_CONNECTOR()¶
ADMIN
ロールで使用できるエントリポイントプロシージャ。このプロシージャはJava関数 ResumeConnectorHandler.resumeConnector
を呼び出します。
PUBLIC.RESUME_CONNECTOR_VALIDATE()¶
一時停止プロセスのコネクタ固有の検証に使用されるプロシージャ。デフォルトでは 'response_code': 'OK'
を返します。これは DefaultResumeConnectorStateValidator
によって呼び出されます。SQL でもJavaでも上書きできます。
PUBLIC.RESUME_CONNECTOR_INTERNAL()¶
コネクタ固有の追加の一時停止機能に使用されるプロシージャ。デフォルトでは 'response_code': 'OK'
を返します。これは InternalResumeConnectorCallback
によって呼び出されます。SQL でもJavaでも上書きできます。
カスタムハンドラー¶
ハンドラーとその内部は、次の2つの方法を使用してカスタマイズできます。
プロシージャの代替アプローチ¶
以下のコンポーネントは SQL を使用して置き換えることができます。
ハンドラー¶
ResumeConnectorHandler
のカスタム実装全体を提供するには、 PUBLIC.RESUME_CONNECTOR
プロシージャを置き換える必要があります。例:
CREATE OR REPLACE PROCEDURE PUBLIC.RESUME_CONNECTOR()
RETURNS VARIANT
LANGUAGE JAVA
RUNTIME_VERSION = '11'
PACKAGES = ('com.snowflake:snowpark:1.11.0')
IMPORTS = ('/connectors-native-sdk.jar')
HANDLER = 'com.custom.handler.CustomResumeConnectorHandler.resumeConnector';
GRANT USAGE ON PROCEDURE PUBLIC.RESUME_CONNECTOR() TO APPLICATION ROLE ADMIN;
内部プロシージャ¶
内部の VALIDATE
および INTERNAL
プロシージャも SQL を通じてカスタマイズできます。別のJavaハンドラーを呼び出すこともできます。
CREATE OR REPLACE PROCEDURE PUBLIC.RESUME_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.RESUME_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.CustomResumeConnectorInternalHandler.resumeConnector';
ビルダーアプローチ¶
ResumeConnectorHandler
は、 ResumeConnectorHandlerBuilder
を使用してカスタマイズできます。このビルダーを使用すると、ユーザーは次のインターフェイスのカスタム実装を提供できます。
ResumeConnectorStateValidator
ResumeConnectorCallback
ConnectorErrorHelper
提供されていない場合は、 SDK が提供するデフォルトの実装が使用されます。
class CustomResumeConnectorStateValidator implements ResumeConnectorStateValidator {
@Override
public ConnectorResponse validate() {
// CUSTOM LOGIC
return ConnectorResponse.success();
}
}
class CustomHandler {
// Path to this method needs to be specified in the PUBLIC.RESUME_CONNECTOR procedure using SQL
public static Variant resumeConnector(Session session) {
//Using builder
var handler = ResumeConnectorHandlerBuilder.builder(session)
.withStateValidator(new CustomResumeConnectorStateValidator())
.build();
return handler.resumeConnector().toVariant();
}
}