Esquema:

ORGANIZATION_USAGE

Exibição PIPES

Importante

Essa exibição só está disponível na conta da organização. Para obter mais informações, consulte Exibições premium na conta da organização.

Essa exibição do Organization Usage exibe uma linha para cada canal definido em uma conta.

Colunas

Colunas em nível de organização

Nome da coluna

Tipo de dados

Descrição

ORGANIZATION_NAME

VARCHAR

Nome da organização.

ACCOUNT_LOCATOR

VARCHAR

Identificador gerado pelo sistema para a conta.

ACCOUNT_NAME

VARCHAR

Identificador definido pelo usuário para a conta.

Colunas adicionais

Nome da coluna

Tipo de dados

Descrição

PIPE_ID

NUMBER

Internal or system-generated identifier for the pipe.

PIPE_NAME

VARCHAR

The name of the pipe object.

For manually created pipes, this is the name defined in the CREATE PIPE statement.

For the Snowpipe Streaming high-performance default pipe, this is derived from the target table name; for example, MY_TABLE-STREAMING.

PIPE_SCHEMA_ID

NUMBER

Internal or system-generated identifier for the schema that the pipe belongs to.

For the default pipe, this corresponds to the target table’s schema ID.

PIPE_SCHEMA

VARCHAR

Esquema ao qual pertence o canal.

For the default pipe, this corresponds to the target table’s schema.

PIPE_CATALOG_ID

NUMBER

Internal or system-generated identifier for the database that the pipe belongs to.

For the default pipe, this corresponds to the target table’s database ID.

PIPE_CATALOG

VARCHAR

Name of the database that the pipe belongs to.

For the default pipe, this corresponds to the target table’s database.

IS_AUTOINGEST_ENABLED

VARCHAR

Se AUTO-INGEST está habilitado para o canal. Representa a funcionalidade futura.

NOTIFICATION_CHANNEL_NAME

VARCHAR

Fila do Amazon Resource Name of the Amazon SQS para o estágio nomeado na coluna DEFINITION. Representa a funcionalidade futura.

PIPE_OWNER

VARCHAR

Nome da função proprietária do canal.

Returns NULL for the default pipe.

DEFINITION

VARCHAR

Instrução COPY usada para carregar dados de arquivos em fila em uma tabela do Snowflake.

CREATED

TIMESTAMP_LTZ

Hora de criação do canal.

LAST_ALTERED

TIMESTAMP_LTZ

Data e hora em que o objeto foi alterado pela última vez por uma operação de metadados de DML, DDL ou em segundo plano. Consulte as Notas de uso.

COMMENT

VARCHAR

Comentário para este canal.

Returns the following message for the default pipe: «Default pipe for Snowpipe Streaming High Performance ingestion to a table. Created and managed by Snowflake.»

PATTERN

VARCHAR

Valor da opção de cópia PATTERN na instrução COPY INTO <tabela> da definição do canal, se a opção de cópia tiver sido especificada

DELETED

TIMESTAMP_LTZ

Data e hora em que o canal foi excluído.

OWNER_ROLE_TYPE

VARCHAR

The type of role that owns the object; for example, ROLE.

If a Snowflake Native App owns the object, the value is APPLICATION.

Snowflake returns NULL if you delete the object because a deleted object doesn’t have an owner role.

Returns NULL for the default pipe.

Notas de uso

  • A latência da exibição pode ser de até 24 horas.

  • A visualização exibe apenas objetos para os quais a função atual da sessão tem privilégios de acesso.

  • A exibição não reconhece o privilégio MANAGE GRANTS e consequentemente pode mostrar menos informações em comparação com um comando SHOW executado por um usuário com o privilégio MANAGE GRANTS.

  • A coluna LAST_ALTERED é atualizada quando as seguintes operações são executadas em um objeto:

    • operações DDL.

    • operações DML (somente para tabelas). Esta coluna é atualizada mesmo quando nenhuma linha é afetada pela instrução DML.

    • Operações de manutenção em segundo plano em metadados realizadas pelo Snowflake.

Exemplos

O exemplo a seguir une esta visualização com Exibição PIPE_USAGE_HISTORY na coluna PIPE_ID para acompanhar o uso de crédito associado a cada objeto PIPE único:

select a.PIPE_CATALOG as PIPE_CATALOG,
       a.PIPE_SCHEMA as PIPE_SCHEMA,
       a.PIPE_NAME as PIPE_NAME,
       b.CREDITS_USED as CREDITS_USED
from SNOWFLAKE.ORGANIZATION_USAGE.PIPES a join SNOWFLAKE.ORGANIZATION_USAGE.PIPE_USAGE_HISTORY b
on a.pipe_id = b.pipe_id
where b.START_TIME > date_trunc(month, current_date);
Copy