SnowConvert AI – Teradata – SnowConvert AI-Skript-Hilfsfunktionen¶

Linux/Mac¶

 export SNOW_AUTHENTICATOR=VALUE
export SNOW_USER=myuser
export SNOW_PASSWORD=mypassword
python3 sample_BTEQ.py

Beschreibung:¶

_Verwenden Sie die echte UID/GID, um den Zugriff auf einen Pfad zu testen

dir_fd, effective_ids und follow_symlinks sind auf Ihrer Plattform möglicherweise nicht implementiert. Wenn sie nicht verfügbar sind, wird bei ihrer Verwendung eine NotImplementedError angezeigt.

_Beachten Sie, dass die meisten Operationen die effektive UID/GID verwenden werden. Daher kann diese Routine in einer SUID/SGID-Umgebung verwendet werden, um zu testen, ob der aufrufende Benutzer den angegebenen Zugriff auf den Pfad hat

Parameter:¶

• path, Zu testender Pfad; kann eine Zeichenfolge, Bytes oder ein pfadähnliches Objekt sein

• mode, Bitfeld für den Betriebssystemmodus. Kann F_OK sein, um die Existenz zu testen, oder das inklusive OR von R_OK, W_OK, und X_OK

• dir_fd, Wenn es nicht None ist, sollte es ein Dateideskriptor sein, der für ein Verzeichnis geöffnet ist, und der Pfad sollte relativ sein; der Pfad ist dann relativ zu diesem Verzeichnis

• effective_ids, Wenn „true“, verwendet der Zugriff die effektive UID/GID anstelle der realen UID/GID

• follow_symlinks, Wenn „false“ und das letzte Element des Pfads ein symbolischer Link ist, überprüft „access“ den symbolischen Link selbst anstelle der Datei, auf die der Link verweist

Beschreibung:¶

wird am Ende der Ausführung des Skripts ausgeführt

Beschreibung:¶

Druckt farbigen Text in der angegebenen Farbe.

Parameter:¶

• text , Der zu druckende Text

• color="blue" , Die zu druckende Farbe

Beschreibung:¶

konfiguriert die Protokollierung, die für jede datenbezogene Ausführung für die Snowflake-Verbindung durchgeführt wird. Die Protokolldatei heißt standardmäßig „snowflake_python_connector.log“._

Parameter:

• configuration_path , Der Konfigurationspfad der Datei, die alle gewünschten Einstellungen für die Protokollierung enthält

Beschreibung:¶

löscht die transiente Tabelle mit dem angegebenen Namen

Parameter:

• tempTableName , Der Name der temporären Tabelle

• con=None , Die zu verwendende Verbindung, wenn None übergeben wird, wird die zuletzt durchgeführte Verbindung verwendet

Beschreibung:¶

Parameter:

• exctype

• Wert

• tback

Beschreibung:¶

Führt eine SQL-Zeichenfolge unter Verwendung der letzten Verbindung aus, optional unter Verwendung von Argumenten oder einer bestimmten Verbindung. Beispiele:

• _ exec("SELECT * FROM USER")_

• _ exec("SELECT * FROM USER", con)_

• _ exec("SELECT * FROM CUSTOMER WHERE CUSTOMERID= %S", customer)_

Parameter:

• sql_string , Die Definition der SQL

• using=None , Der optionale Parameter, der in der übergebenen SQL verwendet werden kann

• con=None , Die zu verwendende Verbindung, wenn None übergeben wird, wird die zuletzt durchgeführte Verbindung verwendet

Beschreibung:¶

liest den Inhalt einer Datei und führt die darin enthaltenen SQL-Anweisungen mit der angegebenen Verbindung aus

Parameter:

• filename , Der Dateiname, der gelesen und ausgeführt werden soll

• con=None , Die zu verwendende Verbindung, wenn None übergeben wird, wird die zuletzt durchgeführte Verbindung verwendet

Beschreibung:¶

führt einen Befehl im operativen System aus

Beschreibung:¶

Führt eine SQL-Anweisung in der übergebenen Verbindung mit den optionalen Argumenten aus.

Parameter:

• sql_string , Die SQL-Anweisung, die die auszuführende Zeichenfolge enthält

• con , Die zu verwendende Verbindung

• using , Die optionalen Parameter, die bei der SQL-Ausführung verwendet werden sollen

Beschreibung:¶

Erweitert die mit den Parametern übergebene Anweisung.

Parameter:

• statement , Die SQL-Anweisung mit der auszuführenden Zeichenfolge

• Params , Die Parameter der SQL-Anweisung

Beschreibung:¶

Erweitert die Variable anhand der übergebenen Zeichenfolge.

Parameter:

• str , Die mit den Variablen zu erweiternde Zeichenfolge

Beschreibung:¶

Erweitern Sie die Umgebungsvariablen der Form $var und ${var}. Wenn der Parameter ‚skip_escaped‘ auf „true“ gesetzt ist, werden alle Variablenreferenzen mit Escape-Zeichen (d. h. denen ein Backslash vorangestellt ist) übersprungen. Unbekannte Variablen werden auf „default“ gesetzt. Wenn „default“ None ist, bleiben sie unverändert.

Parameter:

• path ,

• params ,

• skip_escaped=False ,

Beschreibung:¶

Führt das schnelle Laden mit den übergebenen Parametern target_schema, filepath, stagename und target_table_name aus.

Parameter:

• target_schema , Der Name des Schemas, das beim schnellen Laden verwendet werden soll

• filepath , Der Pfad des Dateinamens, der in die Tabelle geladen werden soll

• target_table_name , Der Name der Tabelle, in die die Daten geladen werden sollen

• con=None , Die zu verwendende Verbindung, wenn None übergeben wird, wird die zuletzt durchgeführte Verbindung verwendet

Beschreibung:¶

Parameter:

• filename ,

Beschreibung:¶

Holt das Argument Schlüsselwert aus der übergebenen Zeichenfolge. Sie muss mit der Zeichenfolge ‚–param-‘ beginnen

Parameter:

• astr , Die zu verwendende Argumentzeichenfolge. Die Zeichenfolge sollte einen ähnlichen Wert haben wie –param-column=32 und die zurückgegebene Zeichenfolge lautet ‚32

Beschreibung:¶

-Holt die Fehlerposition aus der Datei anhand der Informationen des Stapels des erzeugten Fehlers._

Beschreibung:¶

Holt das Argument von der angegebenen Position oder holt den Wert aus der Tabelle vars oder holt den Namen der übergebenen Umgebungsvariablen.

Parameter:

• arg_pos , Die zu verwendende Position des Arguments aus dem Parameter „Arguments“

• variable_name , Der Name der abzurufenden Variable

• vars , Der Hashwert mit den Namen und Werten der Variablen

• args , Der Array-Parameter „Arguments“

Beschreibung:¶

Importiert Daten in eine temporäre Tabelle unter Verwendung eines Platzhalters für Eingabedaten.

Parameter:

• tempTableName, Der Name der temporären Tabelle.

• inputDataPlaceholder, Der verwendete Eingabeplatzhalter, der ein Stagingbereich in der Snowflake-Datenbank ist

• con, Die zu verwendende Verbindung

Beschreibung:¶

Importiert den übergebenen Dateinamen mit dem optionalen Trennzeichen.

Parameter:

• filename, Der Pfad des zu importierenden Dateinamens

• separator=' ', Das optionale Trennzeichen

Beschreibung:¶

Importiert die übergebene Datei in eine temporäre Tabelle. Verwendet einen öffentlichen Stagingbereich, der als temporäre Tabelle mit dem Präfix Stagingbereich_ benannt wird. Am Ende des Ladevorgangs in die temporäre Tabelle wird der Stagingbereich gelöscht, der in diesem Prozess verwendet wurde.

Parameter:

• filename, Der Name der zu lesenden Datei

• tempTableName, Der Name der temporären Tabelle

• columnDefinition, Die Definition aller Felder, die die temporäre Tabelle haben wird

Beschreibung:¶

Beschreibung:¶

Druckt eine Meldung auf der Konsole (Standardausgabe) oder in der Protokolldatei, je nachdem, ob die Protokollierung aktiviert ist

Parameter:

• *msg, Die zu druckende oder zu protokollierende Nachricht

• level=20,

• writter=None,

Beschreibung:¶

Meldet sich bei der Snowflake-Datenbank mit den übergebenen Parametern user, password, database, warehouse, role, login_timeout and authenticator an.

Parameter:

• user, Der Benutzer der Datenbank

• password Das Kennwort des Benutzers der Datenbank

• database, Die zu verbindende Datenbank

• warehouse, Das Warehouse der zu verbindenden Datenbank

• role, Die zu verbindende Rolle

• login_timeout, Der maximale Timeout, bevor eine Fehlermeldung ausgegeben wird, wenn die Verbindung zu lange dauert

• authenticator, Der vom Authentifikator unterstützte Wert, z. B. SNOWFLAKE, EXTERNALBROWSER, SNOWFLAKE_JWT oder OAUTH

• token, Das OAUTH- oder JWT-Token

Beschreibung:¶

Parameter:

• args,

Beschreibung:¶

Druckt das Wörterbuch, ohne die Werte von Benutzern und Kennwörtern preiszugeben.

Parameter:

• dictionary,

Beschreibung:¶

Beendet die Anwendung und gibt optional den übergebenen Code zurück.

Parameter:

• code=None, Der Code, der nach dem Beenden zurückgegeben wird

Beschreibung:¶

Liest die Parameterargumente aus dem übergebenen Array.

Parameter:

• args, Die zu verwendenden Argumente

Beschreibung:¶

Liest die angegebenen Zeilen des Dateinamens und überspringt optional einige Zeilen am Anfang der Datei.

Parameter:

• line, Der zu lesende Dateiname

• skip=0, Die zu überspringenden Zeilen

Beschreibung:¶

Druckt das Argument.

Parameter:

• arg, Das zu druckende Argument

Beschreibung:¶

Wiederholt die zuvor ausgeführte(n) SQL-Anweisung(en).

Parameter:

• con=None, Verbindung, falls angegeben. Wenn sie nicht übergeben wird, wird die zuletzt durchgeführte Verbindung verwendet

• n=1, Die Anzahl der vorherigen Anweisungen, die erneut ausgeführt werden sollen

Beschreibung:¶

Parameter:

• severity_value,

Beschreibung:¶

Parameter:

• arg,

• severity_value,

Beschreibung:¶

Führt eine einfache Schnellladung in der Verbindung und den übergebenen Parametern target_schema, filepath, stagename und target table name aus.

Parameter:

• arg, Die zu verwendende Verbindung

• target_schema, Der Name des Schemas, das beim schnellen Laden verwendet werden soll

• filepath, Der Pfad des Dateinamens, der in die Tabelle geladen werden soll

• target_table_name, Der Name der Tabelle, in die die Daten geladen werden sollen

Beschreibung:¶

Führen Sie einen stat-Systemaufruf für den angegebenen Pfad durch. dir_fd und follow_symlinks sind auf Ihrer Plattform möglicherweise nicht implementiert. Wenn sie nicht verfügbar sind, wird bei ihrer Verwendung eine NotImplementedError-Meldung angezeigt. Es ist ein Fehler, dir_fd oder follow_symlinks zu verwenden, wenn der Pfad als offener Dateideskriptor angegeben wird

Parameter:

• path, Zu untersuchender Pfad; kann eine Zeichenfolge, Bytes, ein pfadähnliches Objekt oder\ open-file-descriptor int sein

• dir_fd, Falls nicht None, sollte es sich um einen Dateideskriptor handeln, der für ein Verzeichnis geöffnet ist, und „path“ sollte eine relative Zeichenfolge sein; „path“ ist dann relativ zu diesem Verzeichnis

• follow_symlinks, Wenn „false“, und das letzte Element des Pfades ein symbolischer Link ist, untersucht „stat“ den symbolischen Link selbst anstatt der Datei, auf die der Link zeigt

Beschreibung:¶

Führen Sie den Befehl in einer Subshell aus.

Parameter:

• _ command_ ,

Beschreibung:¶

Parameter:

• _ *argv_ ,

import_file_to_tab()¶

Parameter:

1. target_schema_table

   • Das Zielschema (optional) und den Tabellennamen

2. define_file

   • Der Name der zu lesenden Datei

3. definieren_Spalten

   • Die Definition aller Spalten für die temporäre Tabelle

4. begin_loading_columns

   • Die einzufügenden Spaltennamen. Legt die Reihenfolge fest, in der die Werte eingefügt werden

5. begin_loading_values

   • Die Liste der zu konvertierenden rohen Einfügewerte

6. field_delimiter

   • Das Feldtrennzeichen

7. (optional) skip_header

   • Die Anzahl der zu überspringenden Zeilen

8. (optional) input_data_place_holder

   • Der Speicherort der Datei bei einem unterstützten Cloud-Anbieter. Parameter setzen, wenn die Datei nicht lokal gespeichert ist

9. (optional) con

   • Die zu verwendende Verbindung

¶