PutSnowpipeStreaming2 2025.10.2.19¶
Bundle¶
com.snowflake.openflow.runtime | runtime-snowpipe-streaming-2-processors-nar
Description¶
Envoyer des enregistrements au format JSON délimité par des sauts de ligne vers les canaux de la base de données Snowflake à l’aide de Snowpipe Streaming version 2.
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Compte |
Identificateur de compte Snowflake avec le nom de l’organisation et le nom du compte formatés comme suit : [nom-de-l’organisation]-[nom-de-compte] |
Stratégie d’authentification |
Stratégie d’authentification des connexions Snowflake |
Groupe de canaux |
Groupe pour la gestion de canaux Snowpipe Streaming distincts avec partitionnement |
Expiration de l’insertion du canal |
Durée maximale de nouvelle tentative d’insertion d’enregistrements avant l’échec avec une limite supérieure de 5 minutes |
Base de données |
Destination de la base de données Snowflake pour les enregistrements traités |
Nombre de fragments de fichier |
Nombre maximum de fragments de fichier envoyés au stockage d’objets pour l’ingestion de Snowpipe Streaming à partir de l’entrée FlowFiles. Doit être compris entre 1 et 100. |
Taille de fragment de fichier |
Taille maximale en octets pour chaque fragment de fichier envoyé au stockage d’objets pour l’ingestion de Snowpipe Streaming. Doit être comprise entre Ko et 256 Mo. |
Expression de fin de jeton de décalage |
Définition du langage d’expression pour produire le jeton de décalage le plus élevé pour un FlowFile sous forme de nombre monotone croissant |
Pointeur d’enregistrement de jeton de décalage |
Pointeur JSON vers le jeton de décalage dans chaque enregistrement requis lorsque le dernier jeton de décalage validé se trouve entre les limites de début et de fin |
Expression de début de jeton de décalage |
Définition du langage d’expression pour produire le plus petit jeton de décalage pour un FlowFile sous forme de nombre monotone croissant |
Délai de suivi des décalages |
Durée maximale d’interrogation du statut du canal pour les jetons de décalage validés |
Canal |
Destination du tuyau Snowflake (Snowpipe) pour les enregistrements traités |
Service de clé privée |
Service de clé privée RSA pour l’authentification des connexions |
Schéma |
Destination du schéma Snowflake pour les enregistrements traités |
Stratégie de transfert |
Stratégie de transfert d’enregistrements vers Snowpipe Streaming |
Utilisateur |
Utilisateur de Snowflake pour l’authentification des connexions |
Fournisseur de services pour le client Web |
Fournisseur de services clients Web prenant en charge le traitement des requêtes et des réponses HTTP |
Relations¶
Nom |
Description |
|---|---|
failure |
FlowFiles qui n’a pas pu être téléchargé vers Snowflake |
invalid |
FlowFiles que Snowflake a identifié comme contenant une ou plusieurs lignes non valides entraînant une transmission partielle |
success |
FlowFiles correctement chargé(s) vers Snowflake |