Callbacks¶

Synchrone Callbacks¶

Synchrone Callbacks werden als Teil des auslösenden SQL-Befehls aufgerufen. Synchrone Callbacks blockieren den aufrufenden SQL-Befehl. Wenn der Callback einen Fehler zurückgibt, gibt der Befehl einen Fehler zurück, und die Fehlermeldung des Callbacks wird als Teil der SQL-Fehlermeldung des Befehls zurückgegeben.

Synchrone Callbacks werden in einem Warehouse ausgeführt, sodass für die aufrufende Prozedur ein Sitzungs-Warehouse festgelegt werden muss.

Asynchrone Callbacks¶

Asynchrone Callbacks werden im Hintergrund ausgeführt, nachdem der aufrufende SQL -Befehl abgeschlossen wurde. Asynchrone Callbacks blockieren den aufrufenden SQL-Befehl nicht, und Fehler in asynchronen Callbacks werden vom aufrufenden Befehl nicht zurückgegeben.

Um sicherzustellen, dass ein asynchroner Callback über die aktuellsten Informationen verfügt, enthält die Callback-Signatur keine Zustands- oder Statusinformationen. Stattdessen sollte der Callback die aktuellen Informationen unter Verwendung der entsprechenden SQL-Befehle, wie SHOW CONFIGURATIONS oder SHOW SPECIFICATIONS, abrufen. Weitere Informationen finden Sie in den Beschreibungen zu jedem asynchronen Callback.

Der Rückgabewert von asynchronen Callbacks wird ignoriert.

Berechtigungen¶

Die in diesem Thema aufgeführten Callback-Prozeduren müssen keiner Anwendungsrolle zugewiesen werden. Die Prozedur kann App-intern sein und muss nicht vom Verbrauchenden ausgeführt werden. Snowflake Native App Framework löst den Callback aus.

Spezifikations- im Vergleich zu Verbindungs-Callbacks¶

Sowohl after_specification_change als auch after_server_connection_change werden ausgeführt, wenn eine Spezifikation genehmigt oder abgelehnt wurde. Die Unterschiede zwischen den beiden Callbacks sind wie folgt:

• after_specification_change ist Teil des Frameworks für Anwendungsspezifikationen. Er wird nur ausgelöst, wenn der Verbrauchende eine Spezifikationsanforderung genehmigt oder ablehnt.

• after_server_connection_change ist Teil des Frameworks für die Kommunikation zwischen Apps. Er wird durch jede Operation ausgelöst, die sich direkt oder indirekt auf den Verbindungsstatus der Anwendungsspezifikation auswirkt, einschließlich der folgenden:

  • Genehmigen einer Spezifikation

  • Ablehnen einer genehmigten Spezifikation

  • Löschen einer genehmigten Spezifikation

  • Löschen der Server-Anwendung

Verwenden Sie after_server_connection_change, wenn Ihre App auf Änderungen in der Verbindung selbst reagieren muss, z. B. wenn eine Verbindung hergestellt wird, verloren geht oder die Server-Anwendung gelöscht wird. Dieser Callback bietet eine bessere Verbindungsverfolgung, da er einen größeren Bereich von Ereignissen abdeckt als nur die Genehmigung von Spezifikationen.

Verwenden Sie after_specification_change, wenn Ihre App nur auf die Genehmigung oder Ablehnung einer Spezifikationsanfrage reagieren muss, oder wenn Sie andere Anwendungsspezifikationstypen als CONNECTION verarbeiten.

Konfigurations-Callbacks¶

Diese Callbacks werden ausgelöst, wenn sich eine Konfiguration ändert.

• validate_configuration_change

• before_configuration_change

• after_configuration_change

validate_configuration_change(configuration_name, configuration_value)

{
  "type": "SUCCESS | ERROR",
  "payload":{
      "error_message": "Error message indicating the validation failure"
  }
}

before_configuration_change(configuration_name, configuration_value)

after_configuration_change(configuration_name)

session.sql(f"""
  SHOW CONFIGURATIONS ->>
      SELECT "status", "value"
      FROM $1
      WHERE "name" = '{configuration_name}';
  """);

Verbindungs-Callbacks¶

Diese Callbacks werden ausgelöst, wenn sich der Status einer Verbindung ändert.

• after_server_connection_change

• after_client_connection_change

• after_server_version_change

after_server_connection_change(server_name)

session.sql(f"""
  SHOW SPECIFICATIONS ->>
  SELECT "status"
  FROM $1
  WHERE PARSE_JSON("definition"):"SERVER_APPLICATION"::STRING = '{server_name}';
  """);

after_client_connection_change(client_name)

session.sql(f"""
  SHOW GRANTS TO APPLICATION {client_name} ->>
  SELECT "name"
  FROM $1
  WHERE "granted_on" = 'APPLICATION_ROLE'
      AND STARTSWITH("name", CURRENT_DATABASE())
  """);

after_server_version_change(server_name)

session.sql(f"""
  SHOW APPLICATIONS ->>
  SELECT "version", "patch"
  FROM $1
  WHERE "name" = {server_name}
  """);

Spezifikations-Callbacks¶

Der Callback wird ausgelöst, wenn eine Spezifikation eines beliebigen Typs eine Statusänderung aufweist

• after_specification_change

after_specification_change(spec_name)

session.sql(f"""
  SHOW SPECIFICATIONS ->>
      SELECT "status"
      FROM $1
      WHERE "name" = '{spec_name}';
  """);