Kategorien:

Information Schema, Tabellenfunktionen

VALIDATE_PIPE_LOAD

Mit dieser Tabellenfunktion können Datendateien überprüft werden, die von Snowpipe innerhalb eines bestimmten Zeitraums verarbeitet wurden. Die Funktion gibt Details zu Fehlern zurück, die während eines versuchten Datenladevorgangs in Snowflake-Tabellen aufgetreten sind.

Bemerkung

Diese Funktion gibt Pipeaktivitäten in den letzten 14 Tagen zurück.

Syntax

VALIDATE_PIPE_LOAD(
      PIPE_NAME => '<string>'
       , START_TIME => <constant_expr>
      [, END_TIME => <constant_expr> ] )
Copy

Argumente

PIPE_NAME => string

Eine Zeichenfolge, mit der eine Pipe angegeben wird. Die Funktion gibt nur Ergebnisse für die angegebene Pipe zurück.

START_TIME => constant_expr

Zeitstempel (im Format TIMESTAMP_LTZ) aus den letzten 14 Tagen, der den Beginn des Zeitbereichs zum Abrufen von Ladeereignissen markiert.

Optional:

END_TIME => constant_expr

Zeitstempel (im Format TIMESTAMP_LTZ) aus den letzten 14 Tagen, der das Ende des Zeitbereichs zum Abrufen von Ladeereignissen markiert.

Nutzungshinweise

  • Gibt Ergebnisse nur für den Pipe-Eigentümer (d. h. die Rolle mit der Berechtigung OWNERSHIP für die Pipe) oder eine Rolle mit den folgenden Mindestberechtigungen zurück:

    Berechtigung

    Objekt

    Anmerkungen

    MONITOR

    Pipe

    Alternativ wird die globale Berechtigung MONITOR EXECUTION unterstützt.

    USAGE

    Stagingbereich in der Pipe-Definition

    Nur für externe Stagingbereiche

    READ

    Stagingbereich in der Pipe-Definition

    Nur für interne Stagingbereiche

    SELECT

    Tabelle in der Pipe-Definition

    INSERT

    Tabelle in der Pipe-Definition

    SQL-Operationen auf Schemaobjekten erfordern ebenfalls die USAGE-Berechtigung für die Datenbank und das Schema, die das Objekt enthalten.

  • Beim Aufrufen einer Tabellenfunktion des Information Schema muss die Sitzung über ein aktives INFORMATION_SCHEMA-Schema verfügen oder der Funktionsname muss vollqualifiziert sein. Weitere Details dazu finden Sie unter Snowflake Information Schema.

  • Wenn Snowpipe beim Verarbeiten von Datendateien innerhalb des angegebenen Zeitraums keine Fehler feststellte, gibt die Funktion keine Ergebnisse zurück.

  • Wenn die COPY-Anweisung in der Pipe-Beschreibung eine Abfrage enthält, um die Daten während des Ladens weiter zu transformieren (d. h. eine COPY-Transformation), gibt die Funktion derzeit einen Benutzerfehler zurück.

  • Wenn der Bereich außerhalb der letzten 15 Tage liegt, wird ein Fehler zurückgegeben.

Ausgabe

Die Funktion gibt die folgenden Spalten zurück:

Spaltenname

Datentyp

Beschreibung

ERROR

TEXT

Erster Fehler in der Quelldatei.

FILE

TEXT

Name der Quelldatei, in der der Fehler aufgetreten ist.

LINE

NUMBER

Nummer der Zeile in der Quelldatei, in der der Fehler aufgetreten ist.

CHARACTER

NUMBER

Position des Zeichens, bei dem der Fehler aufgetreten ist.

BYTE_OFFSET

NUMBER

Byte-Offset zu dem Zeichen, bei dem der Fehler aufgetreten ist.

CATEGORY

TEXT

Kategorie der Operation, bei der der Fehler aufgetreten ist.

CODE

NUMBER

ID für die in der Spalte ERROR angezeigte Fehlermeldung.

SQL_STATE

NUMBER

SQL-Statuscode.

COLUMN_NAME

TEXT

Name und Reihenfolge der Spalte, die den Fehler enthielt.

ROW_NUMBER

NUMBER

Nummer der Zeile in der Quelldatei, in der der Fehler aufgetreten ist.

ROW_START_LINE

NUMBER

Nummer der ersten Zeile der Tabellenzeile, in der der Fehler aufgetreten ist.

REJECTED_RECORD

TEXT

Datensatz, der den Fehler enthielt.

Beispiele

Überprüfen Sie alle Workloads für die mypipe-Pipe innerhalb der letzten Stunde:

select * from table(validate_pipe_load(
  pipe_name=>'MY_DB.PUBLIC.MYPIPE',
  start_time=>dateadd(hour, -1, current_timestamp())));
Copy