Introdução às tarefas¶

Limitações¶

• O tamanho máximo de computação para uma tarefa sem servidor é equivalente a um warehouse virtual XXLARGE.

Criação de uma tarefa usando o modelo de computação sem servidor¶

Use CREATE TASK para definir a tarefa. Não inclua o parâmetro WAREHOUSE.

A função que executa a tarefa deve ter o privilégio global EXECUTE ​​MANAGED TASK. Para obter mais informações, consulte Segurança de tarefas.

O exemplo a seguir cria uma tarefa que é executada a cada hora.

CREATE TASK SCHEDULED_T1
  SCHEDULE='60 MINUTES'
  AS SELECT 1;

from datetime import timedelta
from snowflake.core.task import Cron, Task

tasks = root.databases["TEST_DB"].schemas["TEST_SCHEMA"].tasks

task = tasks.create(
    Task(
        name="SCHEDULED_T1",
        definition="SELECT 1",
        schedule=timedelta(minutes=60),
        ),
    )

Custo e desempenho: tamanhos de warehouse¶

Para garantir que as tarefas sem servidor sejam executadas com eficiência, você pode definir os tamanhos mínimo e máximo de warehouse <label-warehouse_size> definindo os seguintes parâmetros:

• SERVERLESS_TASK_MIN_STATEMENT_SIZE: o tamanho mínimo do warehouse para desempenho previsível (padrão: XSMALL).

• SERVERLESS_TASK_MAX_STATEMENT_SIZE: o tamanho máximo do warehouse para evitar custos inesperados (padrão: XXLARGE).

Após a conclusão de uma tarefa, o Snowflake analisa o desempenho e ajusta os recursos de computação para execuções futuras dentro desses limites.

O exemplo a seguir mostra uma tarefa executada a cada 30 segundos, com um tamanho mínimo de warehouse de SMALL e um tamanho máximo de warehouse de LARGE.

CREATE TASK SCHEDULED_T2
  SCHEDULE='30 SECONDS'
  SERVERLESS_TASK_MIN_STATEMENT_SIZE='SMALL'
  SERVERLESS_TASK_MAX_STATEMENT_SIZE='LARGE'
  AS SELECT 1;

from datetime import timedelta
from snowflake.core.task import Cron, Task

tasks = root.databases["TEST_DB"].schemas["TEST_SCHEMA"].tasks

task = tasks.create(
    Task(
        name="SCHEDULED_T2",
        definition="SELECT 1",
        schedule=timedelta(seconds=30),
        serverless_task_min_statement_size="SMALL",
        serverless_task_max_statement_size="LARGE",
        ),
    )

Intervalo de conclusão desejado¶

Você pode definir uma meta anterior para a conclusão de uma tarefa sem servidor. Um intervalo de conclusão desejado é necessário para tarefas acionadas sem servidor.

Quando definido, o Snowflake estima e dimensiona os recursos para serem concluídos dentro do intervalo de conclusão desejado. Quando uma tarefa já atingiu o tamanho máximo de warehouse e está sendo executada por muito tempo, o intervalo de conclusão desejado é ignorado.

No exemplo a seguir, uma tarefa é executada todos os dias à meia-noite, com a meta de conclusão às duas da manhã. O horário de início e o fuso horário são definidos por USING CRON. Se a tarefa atingir o maior tamanho de warehouse, ela poderá ser executada por até três horas antes de finalmente atingir um tempo limite.

CREATE TASK SCHEDULED_T3
  SCHEDULE='USING CRON 0 * * * * America/Los_Angeles'
  TARGET_COMPLETION_INTERVAL='120 MINUTE'
  SERVERLESS_TASK_MAX_STATEMENT_SIZE='LARGE'
  USER_TASK_TIMEOUT_MS = 10800000         -- (3 hours)
  SUSPEND_TASK_AFTER_NUM_FAILURES = 3
  AS SELECT 1;

from datetime import timedelta
from snowflake.core.task import Cron, Task

tasks = root.databases["TEST_DB"].schemas["TEST_SCHEMA"].tasks

task = tasks.create(
    Task(
        name="SCHEDULED_T3",
        definition="SELECT 1",
        schedule=Cron("0 * * * *", "America/Los_Angeles"),
        target_completion_interval=timedelta(minutes=120),
        serverless_task_max_statement_size="LARGE",
        user_task_timeout_ms=10800000,  # (3 hours)
        suspend_task_after_num_failures=3,
    ),
)

Escolher um warehouse¶

Ao escolher um warehouse, considere o seguinte:

• Revise as práticas recomendadas em Considerações sobre warehouses.

• Analise os tempos médios de execução de tarefas usando diferentes warehouses com base no clustering e no tamanho do warehouse. Para obter mais informações, consulte Duração da tarefa.

• Se o warehouse for compartilhado por vários processos, considere o impacto da tarefa em outras cargas de trabalho.

Criar uma tarefa usando o modelo de computação gerenciado pelo usuário¶

Use CREATE TASK e inclua o parâmetro WAREHOUSE.

A função que executa a tarefa deve ter o privilégio global EXECUTE ​​MANAGED TASK. Para obter mais informações, consulte Segurança de tarefas.

O exemplo a seguir cria uma tarefa que é executada a cada hora.

CREATE TASK SCHEDULED_T1
  WAREHOUSE='COMPUTE_WH'
  SCHEDULE='60 MINUTES'
  AS SELECT 1;

Criação de tarefas¶

A criação de tarefas requer uma função com um mínimo dos seguintes privilégios:

Tarefas em execução¶

Após a criação de uma tarefa, o proprietário da tarefa deverá ter os seguintes privilégios para que a tarefa seja executada:

Além disso, a função deve ter as permissões necessárias para executar a instrução SQL executada pela tarefa.

Visualização do histórico de tarefas¶

Para visualizar tarefas, é necessário ter um ou mais dos seguintes privilégios:

• A função ACCOUNTADMIN

• O privilégio OWNERSHIP na tarefa

• O privilégio global MONITOR EXECUTION

Retomada ou suspensão de tarefas¶

Além do proprietário da tarefa, uma função que tenha o privilégio OPERATE para a tarefa pode suspender ou retomar a tarefa. Esta função deve ter o privilégio USAGE para o banco de dados e o esquema que contêm a tarefa. Nenhum outro privilégio é necessário.

Quando uma tarefa é retomada, o Snowflake verifica se a função do proprietário da tarefa tem os privilégios listados em Tarefas em execução.

Criação de uma função personalizada para criar tarefas¶

O Snowflake requer permissões diferentes para criar tarefas sem servidor e gerenciadas pelo usuário.

Por exemplo, para criar tarefas gerenciadas pelo usuário, crie a função personalizada nomeada warehouse_task_creation e conceda a essa função os privilégios CREATE TASK e USAGE no warehouse em que a função pode criar tarefas.

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')
)

Como exemplo de uma função que pode criar tarefas sem servidor; crie uma função personalizada nomeada serverless_task_creation e conceda à função o privilégio CREATE TASK e ao nível da conta o privilégio EXECUTE MANAGED TASK.

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"
)

Criação de uma função personalizada para administrar tarefas¶

Crie uma função personalizada, conceda a ela o privilégio EXECUTE TASK e, em seguida, conceda essa função personalizada a qualquer função de proprietário da tarefa para permitir a alteração de suas próprias tarefas. Para remover a capacidade da função de proprietário da tarefa de executar a tarefa, revogue essa função personalizada da função de proprietário da tarefa.

Por exemplo, crie um nome de função personalizado taskadmin e conceda a essa função o privilégio EXECUTE TASK. Atribua a função taskadmin a uma função de proprietário de tarefa chamada myrole:

USE ROLE securityadmin;

CREATE ROLE taskadmin;

from snowflake.core.role import Role

root.session.use_role("securityadmin")

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

Definia a função ativa para ACCOUNTADMIN antes de conceder privilégios ao nível de conta para a nova função.

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"
)

Defina a função ativa para SECURITYADMIN para mostrar que esta função pode conceder uma função a outra função.

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'))

Para obter mais informações sobre como criar funções personalizadas e hierarquias de funções, consulte Configuração do controle de acesso.

Descarte de uma função de proprietário de tarefa¶

Quando você exclui a função de proprietário de uma tarefa, a tarefa transfere a propriedade para a função que removeu a função de proprietário. Quando uma tarefa transfere a propriedade, ela é pausada automaticamente e novas execuções de tarefas não são agendadas até que o novo proprietário a retome.

Se você descartar a função enquanto a tarefa estiver em execução, a execução da tarefa concluirá o processamento na função descartada.

Controle de acesso¶

A função de proprietário da tarefa deve receber o privilégio IMPERSONATE no usuário especificado por EXECUTE AS USER, e o usuário especificado deve receber a função de proprietário da tarefa.

Quando a tarefa for executada, a função principal da sessão da tarefa será a função de proprietário da tarefa, e as funções secundárias padrão do usuário serão ativadas. Os usuários poderão alternar as funções principais com o comando USE ROLE e ajustar as funções secundárias na sessão de tarefas com o comando USE SECONDARY ROLES.

Compartilhar tarefas usando um usuário de serviço e uma função¶

Para ambientes de produção, recomendamos criar um usuário de serviço separado para representar sua equipe ou processo de negócios. Ao contrário de executar como um usuário de serviço ou pessoa existente, essa prática recomendada ajuda a tornar o fluxo de trabalho mais seguro:

• Quando uma tarefa é executada como um usuário de serviço dedicado, ela obtém acesso apenas aos privilégios pretendidos. Se, em vez disso, um usuário se passar por um usuário diferente, ele obtém acesso a todos os privilégios associados ao outro usuário, o que pode incluir privilégios não pretendidos, incluindo privilégios de usuário concedidos após a criação e retomada da tarefa.

• Uma tarefa executada como um usuário pode ser interrompida se a pessoa sair do departamento ou da organização.

Exemplos: Configurar o usuário de serviço e a função de equipe¶

1. Usando a função de administrador, configure um usuário de serviço a ser usado para a tarefa.

   O exemplo a seguir cria um usuário de serviço chamado task_user:

   USE ROLE ACCOUNTADMIN;
   CREATE USER task_user;
   

   Copy

2. Crie uma função de tarefa e conceda-a ao usuário de serviço:

   CREATE ROLE task_role;
   GRANT ROLE task_role to USER task_user;
   

   Copy

3. Permita que a função de tarefa execute consultas em nome da função de usuário da equipe:

   GRANT IMPERSONATE ON USER task_user TO ROLE task_role;
   

   Copy

4. Conceda os privilégios apropriados à função de tarefa.

   USE ROLE ACCOUNTADMIN;
   
   -- Grant the team role the privileges to create tasks in a specific schema
   GRANT CREATE TASK
     ON SCHEMA schema1
     TO ROLE task_role;
   
   -- Grant the team role the privileges to use a specific warehouse
   GRANT USAGE
     ON WAREHOUSE warehouse1
     TO ROLE task_role;
   
   -- Grant the team role the privileges to run tasks on a serverless compute model
   GRANT EXECUTE MANAGED TASK ON ACCOUNT TO ROLE task_role;
   

   Copy

Executar uma tarefa em nome de um usuário de serviço¶

Após a função de equipe assumir a propriedade da tarefa, os membros da equipe poderão modificá-la e executá-la em nome do usuário de serviço.

Exemplo:

USE ROLE task_owner;

CREATE TASK team_task
  SCHEDULE='12 HOURS'
  EXECUTE AS USER task_user
  AS SELECT 1;

No exemplo anterior, os logs resultantes mostrariam que task_user modificou a tarefa.

(Somente para teste) Permitir que um usuário se passe diretamente por outro¶

Ao testar ou criar protótipos de alterações, você, como administrador, pode permitir que usuários se passem diretamente por outro usuário. Esse cenário, embora aceito, não é recomendado em um ambiente de produção.

1. Configure uma função para representação:

   USE ROLE ACCOUNTADMIN;
   CREATE ROLE janes_role;
   GRANT ROLE janes_role to USER jane;
   GRANT IMPERSONATE ON USER jane TO ROLE janes_role;
   

   Copy

2. Crie uma tarefa usando a nova função:

   USE ROLE janes_role;
   
   CREATE TASK janes_task
     SCHEDULE='60 M' AS SELECT 1;
   

   Copy

3. Conceda a função a outro usuário.

   No exemplo a seguir, a usuária Jane concede acesso ao usuário Billy:

   --Logged in as Jane or account admin
   GRANT ROLE janes_role to USER billy;
   

   Copy

4. O outro usuário modifica a tarefa.

   No exemplo a seguir, o usuário Billy modifica a tarefa:

   -- Logged in as billy
   USE ROLE janes_role;
   
   ALTER TASK janes_task
     SET EXECUTE AS USER jane;
   

   Copy

5. Revise os logs.

   O comando SHOW GRANTS TO ROLE mostraria que Jane concedeu a função a Billy. A exibição QUERY_HISTORY mostraria que Billy modificou a tarefa. Execuções futuras de tarefas ainda apareceriam como executadas por Jane.

   USE ROLE ACCOUNTADMIN;
   
   SHOW GRANTS TO ROLE janes_role;
   
   QUERY_HISTORY()
     WHERE QUERY_TEXT ILIKE '%janes_task%';
   

   Copy