Einführung in Aufgaben¶

Einschränkungen¶

• Die maximale Berechnungsgröße für eine serverlose Aufgabe entspricht einem X2LARGE virtuellen Warehouse.

Erstellen Sie eine Aufgabe mit dem serverlosen Berechnungsmodell¶

Wenn Sie CREATE TASK oder ALTER TASK verwenden, lassen Sie den Parameter WAREHOUSE weg.

Die Rolle, die den Task ausführt, muss über die globale Berechtigung EXECUTE MANAGED TASK verfügen. Weitere Informationen zu den Anforderungen an die Zugriffssteuerung von Aufgaben finden Sie unter Aufgabensicherheit.

Sie können eine gewisse Kontrolle über die Kosten und die Leistung von serverlosen Aufgaben übernehmen, indem Sie die folgenden Parameter einstellen:

• SERVERLESS_TASK_MAX_STATEMENT_SIZE: die maximale Größe des Warehouse, um unerwartete Kosten zu vermeiden.

• SERVERLESS_TASK_MIN_STATEMENT_SIZE: die Mindestgröße des Warehouse für eine vorhersehbare Leistung.

• TARGET_COMPLETION_INTERVAL: die gewünschte Zeit für die Fertigstellung der Aufgabe.

Wenn diese Einstellungen angegeben sind, gilt folgende Rangfolge:

• SERVERLESS_TASK_MAX_STATEMENT_SIZE

• SERVERLESS_TASK_MIN_STATEMENT_SIZE

• TARGET_COMPLETION_INTERVAL

Wie Snowflake serverlose Computeressourcen schätzt¶

Snowflake schätzt automatisch die für eine Aufgabe benötigten Computeressourcen auf der Grundlage des Zielzeitrahmens und der Leistung früherer Aufgabenläufe.

Der Zielzeitrahmen kann mit TARGET_COMPLETION_INTERVAL festgelegt werden. Wenn dieser Wert nicht festgelegt ist, passt Snowflake die Größe der serverlosen Computeressourcen so an, dass sie vor der nächsten geplanten Ausführungszeit abgeschlossen sind.

Nachdem eine Aufgabe abgeschlossen ist, schätzt Snowflake den Bedarf an Computeressourcen wie folgt:

• Wenn Aufgaben zu schnell abgeschlossen werden (innerhalb eines Zeitrahmens, der um einen Faktor kleiner ist als der Zielzeitrahmen), reduziert Snowflake die Ressourcen in den nachfolgenden Läufen um eine Warehouse-Größe.

• Wenn die Aufgaben zu langsam abgeschlossen werden (innerhalb eines Zeitrahmens, der um einen Faktor größer ist als der Zielzeitrahmen), erhöht Snowflake die Ressourcen in den nachfolgenden Läufen um eine Warehouse-Größe.

Beispiele¶

Beispiel 1: Erstellen Sie eine serverlose Aufgabe, die jede Stunde mit einem Zielintervall von 120 Minuten ausgeführt wird:

CREATE TASK SCHEDULED_T1 SCHEDULE='USING CRON 0 * * * * America/Los_Angeles'
TARGET_COMPLETION_INTERVAL='120 MINUTE' AS SELECT 1;

Indem Sie TARGET_COMPLETION_INTERVAL mit einer relativ langen Dauer einstellen, zeigen Sie an, dass es akzeptabel ist, wenn die Ausführung der Aufgabe länger dauert. Snowflake dimensioniert serverlose Berechnungen automatisch so, dass die Aufgabenausführung innerhalb des angegebenen TARGET_COMPLETION_INTERVAL abgeschlossen wird.

Beispiel 2: Erstellen Sie eine serverlose Aufgabe, die jede Stunde mit einer Zielzeit von 10 Minuten ausgeführt wird:

CREATE TASK SCHEDULED_T2 SCHEDULE='USING CRON 0 * * * * UTC'
TARGET_COMPLETION_INTERVAL='10 MINUTE'
SERVERLESS_TASK_MAX_STATEMENT_SIZE='LARGE'
AS SELECT 1;

Wenn Sie TARGET_COMPLETION_INTERVAL mit einer relativ kurzen Dauer einstellen, deutet dies darauf hin, dass Sie es vorziehen, die Aufgabe schnell zu erledigen. Snowflake dimensioniert serverlose Berechnungen automatisch so, dass die Aufgabenausführung innerhalb des angegebenen TARGET_COMPLETION_INTERVAL abgeschlossen wird, bis die SERVERLESS_TASK_MAX_STATEMENT_SIZE erreicht ist.

Beispiel 3: Erstellen Sie eine serverlose Aufgabe, die einmal pro Tag zu einem Zeitpunkt innerhalb eines Zielerfüllungsintervalls und einer Spanne von minimalen und maximalen Warehouse-Größen geplant wird:

CREATE TASK SCHEDULED_T3 SCHEDULE='USING CRON 0 0 * * * UTC'
TARGET_COMPLETION_INTERVAL='180 M'
SCHEDULING_MODE = 'FLEXIBLE'
SERVERLESS_TASK_MIN_STATEMENT_SIZE='MEDIUM' SERVERLESS_TASK_MAX_STATEMENT_SIZE='LARGE' AS SELECT 1;

Mit dieser Konfiguration läuft die serverlose Aufgabe einmal täglich um Mitternacht auf einem mindestens mittleren Warehouse mit einem TARGET_COMPLETION_INTERVAL von 3 Stunden. Snowflake dimensioniert serverlose Berechnungen automatisch so, dass die Aufgabenausführung innerhalb des angegebenen TARGET_COMPLETION_INTERVAL abgeschlossen wird, bis die SERVERLESS_TASK_MAX_STATEMENT_SIZE erreicht ist. Wenn Sie SCHEDULING_MODE als flexibel einstellen, können Sie die Aufgabe zu einem beliebigen Zeitpunkt des Tages beginnen.

Beispiel 4: Erstellen Sie eine serverlose Aufgabe, die einmal am Tag geplant wird, ohne ein Zielintervall für die Fertigstellung:

CREATE TASK SCHEDULED_T4 SCHEDULE='USING CRON 0 0 * * * UTC'
SERVERLESS_TASK_MAX_STATEMENT_SIZE='LARGE' AS SELECT 1;

Mit dieser Konfiguration wird die serverlose Aufgabe einmal täglich um Mitternacht ausgeführt. Wenn eine Reihe von Aufgabenausführungen nicht vor dem nächsten geplanten Zeitpunkt abgeschlossen ist, dimensioniert Snowflake die serverlose Berechnung automatisch so, dass die Aufgabenausführung innerhalb des angegebenen SCHEDULE abgeschlossen wird, bis die SERVERLESS_TASK_MAX_STATEMENT_SIZE erreicht ist.

Weitere Informationen zu den Parametern und der Syntax finden Sie unter CREATE TASK und ALTER TASK.

Auswählen einer Warehouse-Größe¶

Wenn Sie sich dafür entscheiden, bestehende Warehouses für die Bereitstellung von Computeressourcen für einzelne Aufgaben zu verwenden, sollten Sie die unter Hinweise zu Warehouses beschriebenen bewährten Verfahren befolgen. Um den Computing-Bedarf für Ihre Aufgabe zu verstehen, analysieren Sie die durchschnittliche Laufzeit für eine einzelne Aufgabe oder einen Task-Graphen unter Verwendung verschiedener Warehouses auf der Grundlage von Warehouse-Größe und Clustering. Sie sollten auch berücksichtigen, ob das Warehouse von mehreren Prozessen gemeinsam genutzt wird.

Um die durchschnittliche Laufzeit Ihrer Aufgaben zu analysieren, fragen Sie die Account Usage-Ansicht TASK_HISTORY ab. Die durchschnittliche Differenz zwischen der geplanten und der tatsächlichen Ausführungszeit einer Aufgabe ist die erwartete durchschnittliche Ausführungszeit der Aufgabe. Diese Differenz beinhaltet auch die Zeit, in der die Aufgabe in der Warteschlange stand, während andere Prozesse die Computeressourcen im Warehouse nutzen.

Bei Task-Graphen gibt es eine kurze Verzögerung zwischen dem Beenden einer Vorgängeraufgabe und dem Starten einer untergeordnete Aufgabe. Wählen Sie ein Warehouse, das groß genug ist, um mehrere untergeordnete Aufgaben gleichzeitig ausführen zu können.

Die folgende Abbildung zeigt ein Fenster von 1 Minute, in der eine einzelne Aufgabe 20 Sekunden lang in der Warteschlange steht und dann 40 Sekunden lang ausgeführt wird. Das bedeutet, dass andere Prozesse die Warehouse-Ressourcen in den ersten 20 Sekunden nach der geplanten Ausführung der Aufgabe genutzt haben.

Die folgende Abbildung zeigt einen Task-Graphen, für dessen Ausführung durchschnittlich 5 Minuten erforderlich sind. Die Abbildung zeigt das Fenster für 2 Ausführungen des zu bearbeitenden Task-Graphen. Die Berechnung dieses Fensters beginnt beim geplanten Startzeitpunkt der Stammaufgabe und endet, wenn die letzte untergeordnete Aufgabe vollständig ausgeführt wurde.

In diesem Beispiel wird das Warehouse, auf dem der Task-Graph ausgeführt wird, mit anderen gleichzeitigen Operationen geteilt. Diese parallelen Operationen verbrauchen alle verfügbaren Ressourcen, wenn die Ausführung jeder Aufgabe im Task-Graphen beendet ist und bevor die nächste Aufgabe ausgeführt wird. Infolgedessen enthält das Fenster für jede Aufgabe etwas Warteschlangenzeit für das Warten darauf, das andere Operationen abgeschlossen und die Computeressourcen freigegeben werden.

Aufgabenplanung und Sommerzeit¶

Der Cron-Ausdruck in einer Aufgabendefinition unterstützt die Angabe einer Zeitzone. Aufgaben, die an Tagen geplant sind, an denen der Übergang von der Standardzeit zur Sommerzeit (oder umgekehrt) erfolgt, können ein unerwartetes Verhalten aufweisen.

Beispiel:

• Beim Wechsel von der Sommerzeit zur Standardzeit wird eine Aufgabe, die um 1 AM in der Zeitzone Amerika/Los Angeles (0 1 * * * America/Los_Angeles) beginnen soll, zweimal ausgeführt: einmal um 1 AM und noch einmal, wenn 1:59:59 AM auf 1:00:00 AM Ortszeit wechselt.

• Beim Wechsel von der Standardzeit zur Sommerzeit wird eine Aufgabe, die um 2 AM in der Zeitzone Amerika/Los Angeles (0 2 * * * America/Los_Angeles) beginnen soll, nicht ausgeführt, da die lokale Zeit von 1:59:59 AM auf 3:00:00 AM wechselt.

Um unerwartete Aufgabenausführungen aufgrund der Sommerzeit zu vermeiden, beachten Sie Folgendes:

• Planen Sie keine Aufgaben, die zwischen 1 AM und 3 AM ausgeführt werden.

• Passen Sie den Cron-Ausdruck für Aufgaben, die zwischen 1 AM und 3 AM geplant sind, zweimal im Jahr manuell an, um die Zeitumstellung auszugleichen.

• Verwenden Sie ein Zeitformat, das keine Sommerzeit anwendet, z. B. UTC.

Eine getriggerte Aufgabe erstellen¶

Verwenden Sie CREATE TASK, und definieren Sie den Ziel-Stream mit der Klausel WHEN. (Fügen Sie den Parameter SCHEDULE nicht ein.)

Weisen Sie Computeressourcen für die Aufgabe zu, indem Sie eine der folgenden Optionen wählen:

• Um die Ressourcen manuell zu verwalten (vom Benutzer verwaltete Warehouse-Aufgabe), fügen Sie den Parameter WAREHOUSE hinzu.

• Um Snowflake die Verwaltung von Ressourcen zu ermöglichen (serverlose Aufgabe), fügen Sie den Parameter TARGET_COMPLETION_INTERVAL hinzu. Snowflake schätzt die benötigten Ressourcen und stellt sich darauf ein, die Aufgabe in dieser Zeit zu erledigen.

Migrieren Sie eine bestehende Aufgabe von einer geplanten Aufgabe in eine getriggerte Aufgabe¶

Unterbrechen Sie die Aufgabe, deaktivieren Sie den Parameter SCHEDULE, und nehmen Sie die Aufgabe wieder auf. Die bestehende Aufgabe muss einen in der WHEN-Klausel definierten Zielstream haben.

ALTER TASK task SUSPEND;
ALTER TASK task UNSET SCHEDULE;
ALTER TASK task RESUME;

Migrieren Sie eine bestehende, vom Benutzer verwaltete getriggerte Aufgabe in eine serverlose getriggerte Aufgabe¶

Setzen Sie die Aufgabe aus. Entfernen Sie den Parameter WAREHOUSE, und fügen Sie den Parameter TARGET_COMPLETION_INTERVAL hinzu. Nehmen Sie die Aufgabe wieder auf.

Hinweise zu getriggerten Aufgaben¶

• In den Ausgabe von SHOW TASKS und DESC TASK zeigt die Eigenschaft SCHEDULE für getriggerte Aufgaben den Wert NULL an.

• In der Ausgabe der „task_history“-Ansicht der Schemas „information_schema“ und „account_usage“ wird in der Spalte SCHEDULED_FROM der Wert TRIGGER angezeigt.

• Wenn Sie mit mehreren Datenströmen arbeiten, können Sie den Start von Aufgaben mithilfe von bedingten Parametern steuern: WHEN … AND und WHEN … OR.

Einschränkungen bei getriggerten Aufgaben¶

• Standardmäßig werden getriggerte Aufgaben höchstens alle 30 Sekunden ausgeführt. Sie können den Parameter USER_TASK_MINIMUM_TRIGGER_INTERVAL_IN_SECONDS so ändern, dass die Ausführung häufiger erfolgt, bis zu alle 10 Sekunden.

• Streams auf Verzeichnis-Tabellen, externen Tabellen und Hybridtabellen werden nicht unterstützt.

Beispiele für getriggerte Aufgaben¶

Beispiel 1: Erstellen Sie eine vom Benutzer verwaltete Aufgabe, die immer dann ausgeführt wird, wenn sich Daten in einem der beiden Streams ändern:

CREATE TASK my_task
  WHEN SYSTEM$STREAM_HAS_DATA('my_return_stream')
  OR   SYSTEM$STREAM_HAS_DATA('my_order_stream')
  WAREHOUSE = my_warehouse
  AS
    INSERT INTO customer_activity
    SELECT customer_id, return_total, return_date, ‘return’
    FROM my_return_stream
    UNION ALL
    SELECT customer_id, order_total, order_date, ‘order’
    FROM my_order_stream;

Beispiel 2: Erstellen Sie eine Aufgabe, die immer dann ausgeführt wird, wenn Datenänderungen in zwei verschiedenen Datenströmen festgestellt werden. Da die Aufgabe die Bedingung AND verwendet, wird die Aufgabe übersprungen, wenn nur einer der beiden Streams neue Daten enthält.

Da TARGET_COMPLETION_INTERVAL 120 Minuten beträgt, schätzt Snowflake die für die Erledigung der Aufgabe in dieser Zeit erforderlichen Computeressourcen und passt sie an.

CREATE TASK triggeredTask
  WHEN SYSTEM$STREAM_HAS_DATA('orders_stream')
  TARGET_COMPLETION_INTERVAL='120 MINUTES'
  AS
    INSERT INTO completed_promotions
    SELECT order_id, order_total, order_time, promotion_id
    FROM orders_stream
    WHERE promotion_id IS NOT NULL;

Erstellen von Aufgaben¶

Für das Erstellen von Aufgaben ist eine Rolle mit mindestens den folgenden Berechtigungen erforderlich:

Ausführen von Aufgaben¶

Nachdem eine Aufgabe erstellt wurde, muss der Aufgabeneigentümer über die folgenden Berechtigungen verfügen, um die Aufgabe ausführen zu können:

Darüber hinaus muss die Rolle über die erforderlichen Berechtigungen verfügen, um die von der Aufgabe ausgeführte SQL-Anweisung auszuführen.

Aufgabenverlauf anzeigen¶

Um Aufgaben anzuzeigen, müssen Sie über eine oder mehrere der folgenden Berechtigungen verfügen:

• Rolle ACCOUNTADMIN

• OWNERSHIP-Berechtigungen für die Aufgabe

• Die globale Berechtigung MONITOR EXECUTION

Anhalten und Fortsetzen von Aufgaben¶

Zusätzlich zum Aufgabeneigentümer kann eine Rolle mit der Berechtigung OPERATE für die Aufgabe, die Aufgabe anhalten und fortsetzen. Diese Rolle muss die Berechtigung USAGE für die Datenbank und das Schema haben, die die Aufgabe enthalten. Es sind keine weiteren Berechtigungen erforderlich.

Wenn eine Aufgabe fortgesetzt wird, überprüft Snowflake, ob die Rolle des Aufgabeneigentümers die unter Ausführen von Aufgaben aufgeführten Berechtigungen aufweist.

Kundenspezifische Rolle zum Erstellen von Aufgaben erstellen¶

Snowflake erfordert unterschiedliche Berechtigungen für das Erstellen von serverlosen Aufgaben und von benutzerverwalteten Aufgaben.

Um beispielsweise benutzerverwaltete Aufgaben zu erstellen, erstellen Sie eine kundenspezifische Rolle namens warehouse_task_creation und weisen Sie dieser Rolle die Berechtigungen CREATE TASK und USAGE für das Warehouse zu, in dem die Rolle Aufgaben erstellen kann.

USE SYSADMIN;

CREATE ROLE warehouse_task_creation
  COMMENT = 'This role can create user-managed tasks.';

from snowflake.core.role import Role

root.session.use_role("SYSADMIN")

my_role = Role(
    name="warehouse_task_creation",
    comment="This role can create user-managed tasks."
)
root.roles.create(my_role)

USE ACCOUNTADMIN;

GRANT CREATE TASK
  ON SCHEMA schema1
  TO ROLE warehouse_task_creation;

from snowflake.core.role import Securable

root.session.use_role("ACCOUNTADMIN")

root.roles['warehouse_task_creation'].grant_privileges(
    privileges=["CREATE TASK"], securable_type="schema", securable=Securable(name='schema1')
)

GRANT USAGE
  ON WAREHOUSE warehouse1
  TO ROLE warehouse_task_creation;

from snowflake.core.role import Securable

root.roles['warehouse_task_creation'].grant_privileges(
    privileges=["USAGE"], securable_type="warehouse", securable=Securable(name='warehouse1')
)

Als Beispiel für eine Rolle, die serverlose Aufgaben erstellen kann, erstellen Sie eine kundenspezifische Rolle namens serverless_task_creation und weisen der Rolle die Berechtigung CREATE TASK sowie auf Kontoebene die Berechtigung EXECUTE MANAGED TASK zu.

USE SYSADMIN;

CREATE ROLE serverless_task_creation
  COMMENT = 'This role can create serverless tasks.';

from snowflake.core.role import Role

root.session.use_role("SYSADMIN")

my_role = Role(
    name="serverless_task_creation",
    comment="This role can create serverless tasks."
)
root.roles.create(my_role)

USE ACCOUNTADMIN;

GRANT CREATE TASK
  ON SCHEMA schema1
  TO ROLE serverless_task_creation;

from snowflake.core.role import Securable

root.session.use_role("ACCOUNTADMIN")

root.roles['serverless_task_creation'].grant_privileges(
    privileges=["CREATE TASK"], securable_type="schema", securable=Securable(name='schema1')
)

GRANT EXECUTE MANAGED TASK ON ACCOUNT
  TO ROLE serverless_task_creation;

root.roles['serverless_task_creation'].grant_privileges(
    privileges=["EXECUTE MANAGED TASK"], securable_type="account"
)

Kundenspezifische Rolle zum Verwalten von Aufgaben¶

Erstellen Sie eine kundenspezifische Rolle mit der Berechtigung EXECUTE TASK, und weisen Sie diese kundenspezifischen Rolle dann jeder Aufgabeneigentümerrolle zu, um das Ändern ihrer eigenen Aufgaben zu ermöglichen. Um zu verhindern, dass die Aufgabeneigentümerrolle die Aufgabe ausführt, muss der Aufgabeneigentümerrolle diese kundenspezifische Rolle entzogen werden.

Erstellen Sie beispielsweise eine kundenspezifische Rolle mit dem Namen taskadmin, und erteilen Sie dieser Rolle die Berechtigung EXECUTE TASK. Weisen Sie die Rolle taskadmin einer Aufgabeneigentümerrolle mit dem Namen myrole zu:

USE ROLE securityadmin;

CREATE ROLE taskadmin;

from snowflake.core.role import Role

root.session.use_role("securityadmin")

root.roles.create(Role(name="taskadmin"))

Setzen Sie die aktive Rolle auf ACCOUNTADMIN, bevor Sie der neuen Rolle die Berechtigungen auf Kontoebene erteilen.

USE ROLE accountadmin;

GRANT EXECUTE TASK, EXECUTE MANAGED TASK ON ACCOUNT TO ROLE taskadmin;

root.session.use_role("accountadmin")

root.roles['taskadmin'].grant_privileges(
    privileges=["EXECUTE TASK", "EXECUTE MANAGED TASK"], securable_type="account"
)

Setzen Sie die aktive Rolle auf SECURITYADMIN, um zu zeigen, dass diese Rolle einer anderen Rolle eine Rolle zuweisen kann.

USE ROLE securityadmin;

GRANT ROLE taskadmin TO ROLE myrole;

from snowflake.core.role import Securable

root.session.use_role("securityadmin")

root.roles['myrole'].grant_role(role_type="ROLE", role=Securable(name='taskadmin'))

Weitere Informationen zum Erstellen von kundenspezifischen Rollen und Rollenhierarchien finden Sie unter Konfigurieren der Zugriffssteuerung.