Versionshinweise zur Snowpark-Bibliothek für Python 2025¶

Verbesserungen¶

• Der Aufruf von Snowflake-Systemprozeduren führt nicht zu einem zusätzlichen Aufruf von describe procedure, um den Rückgabetyp der Prozedur zu überprüfen.

• Unterstützung für Session.create_dataframe() mit deder Stage-URL und dem Datentyp FILE wurde hinzugefügt.

• Unterstützung für verschiedene Modi zum Umgang mit beschädigten XML-Datensätzen beim Lesen einer XML Datei mit session.read.option('mode', <mode>), option('rowTag', <tag_name>).xml(<stage_file_path>). Derzeit wird PERMISSIVE, DROPMALFORMED und FAILFAST unterstützt.

• Die Fehlermeldung des XML-Readers wurde verbessert, wenn die angegebene ROWTAG nicht in der Datei gefunden wird.

• Die Erstellung von Abfragen für Dataframe.drop wurde verbessert, um SELECT * EXCLUDE () zu verwenden, um die ausgelassenen Spalten auszuschließen. Um dieses Feature zu aktivieren, stellen Sie session.conf.set("use_simplified_query_generation", True) ein.

• Unterstützung für VariantType wurde zu StructType.from_json hinzugefügt.

Fehlerkorrekturen¶

• Es wurde ein Fehler in DataFrameWriter.dbapi (Private Vorschau) behoben, bei dem Spaltennamen in Unicode- oder doppelten Anführungszeichen in externen Datenbanken zu Fehlern führten, weil sie nicht korrekt in Anführungszeichen gesetzt wurden.

• Es wurde ein Fehler behoben, bei dem benannte Felder in verschachtelten OBJECT-Daten Fehler verursachen konnten, wenn sie Leerzeichen enthielten.

Lokale Snowpark-Testaktualisierungen¶

Snowpark Pandas API-Aktualisierungen¶

Neue Features¶

• Unterstützung für die Erlaubnis restricted caller des Arguments execute_as in StoredProcedure.register():code: hinzugefügt.

• Unterstützung für Nicht-Select-Anweisungen in DataFrame.to_pandas() wurde hinzugefügt.

• Unterstützung für den Parameter artifact_repository wurde zu Session.add_packages, Session.add_requirements, Session.get_packages, Session.remove_package und Session.clear_packages hinzugefügt.

• Unterstützung für das Lesen einer XML-Datei unter Verwendung eines Zeilen-Tags durch session.read.option('rowTag', <tag_name>).xml(<stage_file_path>) (experimentell) hinzugefügt.

  • Jeder XML-Datensatz wird als eine separate Zeile extrahiert.

  • Jedes Feld innerhalb dieses Datensatzes wird zu einer separaten Spalte des Typs VARIANT, die unter Verwendung der Punktnotation weiter abgefragt werden kann, z. B. col(a.b.c).

• Aktualisierungen zu DataFrameReader.dbapi (PrPr) hinzugefügt:

  • Der Parameter fetch_merge_count wurde hinzugefügt, um die Leistung zu optimieren, indem mehrere abgerufene Daten in einer einzigen Parquet-Datei zusammengeführt werden.

  • Unterstützung für Databricks wurde hinzugefügt.

  • Unterstützung für das Einlesen mit Snowflake UDTF wurde hinzugefügt.

• Unterstützung für die folgenden AI-fähigen Funktionen in functions.py (Private Vorschau) hinzugefügt:

  • prompt

  • ai_filter (Unterstützung für die Funktion prompt() und Bilddateien hinzugefügt und den Namen des zweiten Arguments von expr in file geändert)

  • ai_classify

Lokale Snowpark-Testaktualisierungen¶

Snowpark Pandas API-Aktualisierungen¶

Neue Features¶

• Unterstützung für lockere Konsistenz- und Ordnungsgarantien in Dataframe.to_snowpark_pandas durch Einführung des Parameters relaxed_ordering.

• DataFrameReader.dbapi (Vorschau) akzeptiert jetzt eine Liste von Strings für den Parameter session_init_statement, so dass mehrere SQL-Anweisungen während der Sitzungsinitialisierung ausgeführt werden können.

Verbesserungen¶

• Die Abfragegenerierung für Dataframe.stat.sample_by wurde verbessert, um eine einzige flache Abfrage zu generieren, die bei einem großen fractions-Wörterbuch gut skaliert, verglichen mit der älteren Methode, für jeden Schlüssel in fractions eine Unterabfrage UNION ALL zu erstellen. Um dieses Feature zu aktivieren, stellen Sie session.conf.set("use_simplified_query_generation", True) ein.

• Die Leistung von DataFrameReader.dbapi wurde verbessert, indem die vektorisierte Option beim Kopieren einer Parkettdatei in eine Tabelle aktiviert wurde.

• Die Generierung von Abfragen für DataFrame.random_split wurde in folgenden Punkten verbessert Sie können durch die Einstellung session.conf.set("use_simplified_query_generation", True) aktiviert werden:

  • In der internen Implementierung des Eingabedatenrahmens ist es nicht mehr erforderlich, cache_result zu verwenden, was zu einer reinen Lazy-Dataframe-Operation führt.

  • Das Argument seed verhält sich jetzt wie erwartet mit wiederholbaren Ergebnissen über mehrere Aufrufe und Sitzungen hinweg.

• DataFrame.fillna und DataFrame.replace unterstützen nun beide das Anpassen von int und float in Decimal-Spalten, wenn include_decimal auf True gesetzt ist.

• Dokumentation für die folgenden UDF und Stored-Procedure-Funktionen in files.py als Ergebnis ihrer allgemeinen Verfügbarkeit hinzugefügt.

  • SnowflakeFile.write

  • SnowflakeFile.writelines

  • SnowflakeFile.writeable

• Kleinere Änderungen in der Dokumentation für SnowflakeFile und SnowflakeFile.open().

Fehlerkorrekturen¶

• Es wurde ein Bug bei den folgenden Funktionen behoben, der zu Fehlern führte. .cast() wird auf deren Ausgabe angewendet:

  • from_json

  • size

Lokale Snowpark-Testaktualisierungen¶

Snowpark Pandas API-Aktualisierungen¶

Lokale Snowpark-Testaktualisierungen¶

Fehlerkorrekturen¶

• Es wurde ein Fehler in DataFrameReader.dbapi (private Vorschau) behoben, der die Verwendung in gespeicherten Prozeduren und Snowbooks verhindert.

Neue Features¶

• Unterstützung für die folgenden AI-fähigen Funktionen in functions.py (Private Vorschau) hinzugefügt:

  • ai_filter

  • ai_agg

  • summarize_agg

• Unterstützung für den neuen Typ FILE SQL mit den folgenden zugehörigen Funktionen in functions.py (Private Vorschau) hinzugefügt:

  • fl_get_content_type

  • fl_get_etag

  • fl_get_file_type

  • fl_get_last_modified

  • fl_get_relative_path

  • fl_get_scoped_file_url

  • fl_get_size

  • fl_get_stage

  • fl_get_stage_file_url

  • fl_is_audio

  • fl_is_compressed

  • fl_is_document

  • fl_is_image

  • fl_is_video

• Unterstützung für den Import von Paketen von Drittanbietern von PyPi mit Hilfe des Artefakt-Repository (Private Vorschau) wurde hinzugefügt:

  • Verwenden Sie die Schlüsselwortargumente artifact_repository und artifact_repository_packages, um bei der Registrierung von gespeicherten Prozeduren oder benutzerdefinierten Funktionen Ihr Artefakt-Repository bzw. Ihre Pakete anzugeben.

  • Unterstützte APIs sind:

    • Session.sproc.register

    • Session.udf.register

    • Session.udaf.register

    • Session.udtf.register

    • functions.sproc

    • functions.udf

    • functions.udaf

    • functions.udtf

    • functions.pandas_udf

    • functions.pandas_udtf

Verbesserungen¶

• Verbesserte Versionsvalidierungswarnungen für snowflake-snowpark-python-Paketkompatibilität bei der Registrierung von gespeicherten Prozeduren. Jetzt werden Warnungen nur noch ausgelöst, wenn die Haupt- oder Nebenversion nicht übereinstimmt, während Bugfix-Versionsunterschiede keine Warnungen mehr erzeugen.

• Die Cloudpickle-Abhängigkeit wurde erhöht, um zusätzlich zu den früheren Versionen auch cloudpickle==3.0.0 zu unterstützen.

Fehlerkorrekturen¶

• Es wurde ein Fehler behoben, bei dem das Erstellen eines Datenrahmens mit einer großen Anzahl von Werten zu einem Unsupported feature 'SCOPED_TEMPORARY'.-Fehler führte, wenn die Thread-sichere Sitzung deaktiviert war.

• Es wurde ein Fehler behoben, bei dem df.describe einen internen SQL-Ausführungsfehler auslöste, wenn DataFrame aus dem Lesen einer Stagingdatei erstellt wurde und die CTE-Optimierung aktiviert war.

• Es wurde ein Fehler behoben, bei dem df.order_by(A).select(B).distinct() ungültige SQL generierte, wenn die vereinfachte Abfragegenerierung mit session.conf.set("use_simplified_query_generation", True) aktiviert war.

  • Standardmäßig ist die vereinfachte Abfrageerstellung deaktiviert.

Snowpark Pandas API-Aktualisierungen¶

Lokale Snowpark-Testaktualisierungen¶

Neue Features¶

• Unterstützung für die folgenden Funktionen in functions.py wurde hinzugefügt:

  • normal

  • randn

• Unterstützung für den Parameter allow_missing_columns wurde zu Dataframe.union_by_name und Dataframe.union_all_by_name hinzugefügt.

Verbesserungen¶

• Die Generierung zufälliger Objektnamen wurde verbessert, um Kollisionen zu vermeiden.

• Die Generierung von Abfragen für Dataframe.distinct wurde verbessert, um SELECT DISTINCT anstelle von SELECT mit GROUP BY in allen Spalten zu generieren. Um dieses Feature zu deaktivieren, stellen Sie session.conf.set("use_simplified_query_generation", False) ein.

Veraltete Funktionen¶

• Veraltete Snowpark Python-Funktion snowflake_cortex_summarize. Benutzer können snowflake-ml-python installieren und stattdessen die Funktion snowflake.cortex.summarize verwenden.

• Veraltete Snowpark Python-Funktion snowflake_cortex_sentiment. Benutzer können snowflake-ml-python installieren und stattdessen die Funktion snowflake.cortex.sentiment verwenden.

Fehlerkorrekturen¶

• Es wurde ein Fehler behoben, bei dem das Abfrage-Tag auf Sitzungsebene durch eine Stapelverfolgung für DataFrames überschrieben wurde, die mehrere Abfragen erzeugt. Jetzt wird das Abfrage-Tag nur dann auf den Stacktrace gesetzt, wenn session.conf.set("collect_stacktrace_in_query_tag", True).

• Ein Fehler in Session._write_pandas wurde behoben, bei dem beim Schreiben eines Snowpark-Pandas-Objekts der Parameter use_logical_type fälschlicherweise an Session._write_modin_pandas_helper übergeben wurde.

• Es wurde ein Fehler bei der Erzeugung von Options-SQL behoben, der dazu führen konnte, dass mehrere Werte falsch formatiert wurden.

• Es wurde ein Fehler in Session.catalog behoben, bei dem leere Zeichenketten für Datenbank oder Schema nicht korrekt behandelt wurden und fehlerhafte SQL-Anweisungen erzeugten.

Experimentelle Features¶

• Unterstützung für das Schreiben von Pyarrow-Tabellen in Snowflake-Tabellen wurde hinzugefügt.

Snowpark Pandas API-Aktualisierungen¶

Fehlerkorrekturen¶

• Ein Fehler in apply wurde behoben, bei dem kwargs nicht korrekt an die angewandte Funktion übergeben wurde.

Lokale Snowpark-Testaktualisierungen¶

Fehlerkorrekturen¶

• Es wurde ein Fehler in DataFrame.join behoben, der dazu führte, dass Spalten falsch eingegeben wurden.

• Es wurde ein Fehler in when-Anweisungen behoben, der zu falschen Ergebnissen in der otherwise-Klausel führte.

Neue Features¶

Unterstützung für die folgenden Funktionen in functions.py wurde hinzugefügt:

• array_reverse

• divnull

• map_cat

• map_contains_key

• map_keys

• nullifzero

• snowflake_cortex_sentiment

• acosh

• asinh

• atanh

• bit_length

• bitmap_bit_position

• bitmap_bucket_number

• bitmap_construct_agg

• cbrt

• equal_null

• from_json

• ifnull

• localtimestamp

• max_by

• min_by

• nth_value

• nvl

• octet_length

• position

• regr_avgx

• regr_avgy

• regr_count

• regr_intercept

• regr_r2

• regr_slope

• regr_sxx

• regr_sxy

• regr_syy

• try_to_binary

• base64

• base64_decode_string

• base64_encode

• editdistance

• hex

• hex_encode

• instr

• log1p

• log2

• log10

• percentile_approx

• unbase64

• Unterstützung für die Angabe einer Schema-Zeichenfolge (einschließlich impliziter struct-Syntax) beim Aufruf von DataFrame.create_dataframe wurde hinzugefügt.

• Unterstützung von DataFrameWriter.insert_into/insertInto hinzugefügt. Diese Methode unterstützt auch den lokalen Testmodus.

• Unterstützung für DataFrame.create_temp_view wurde hinzugefügt, um eine temporäre Ansicht zu erstellen. Dies schlägt fehl, wenn die Ansicht bereits existiert.

• Unterstützung für mehrere Spalten in den Funktionen map_cat und map_concat wurde hinzugefügt.

• Es wurde eine Option keep_column_order hinzugefügt, um die ursprüngliche Spaltenreihenfolge in DataFrame.with_column und DataFrame.with_columns beizubehalten.

• Es wurden Optionen zu den Spaltenumwandlungen hinzugefügt, die das Umbenennen oder Hinzufügen von Feldern in StructType-Spalten ermöglichen.

• Unterstützung für contains_null parameter wurde zu ArrayType hinzugefügt.

• Es wurde Unterstützung für die Erstellung einer temporären Ansicht über DataFrame.create_or_replace_temp_view aus einem DataFrame hinzugefügt, der durch Lesen einer Datei aus einem Stagingbereich erstellt wurde.

• Unterstützung für den Parameter value_contains_null wurde zu MapType hinzugefügt.

• Interaktiv wurde zur Telemetrie hinzugefügt, die anzeigt, ob die aktuelle Umgebung eine interaktive ist.

• Erlauben Sie session.file.get in einer Native App, Dateipfade, die mit / beginnen, aus der aktuellen Version zu lesen

• Unterstützung für mehrere Aggregationsfunktionen nach DataFrame.pivot hinzugefügt.

Experimentelle Features¶

• Die Klasse Session.catalog wurde hinzugefügt, um Snowflake-Objekte zu verwalten. Sie kann über Session.catalog aufgerufen werden.

  • snowflake.core ist eine für dieses Feature erforderliche Abhängigkeit.

• Erlauben Sie die Eingabe von Schemata durch den Benutzer oder die Eingabe von Schemata durch den Benutzer beim Lesen der Datei JSON im Stagingbereich.

• Unterstützung für die Angabe einer Schema-Zeichenfolge (einschließlich impliziter struct-Syntax) beim Aufruf von DataFrame.create_dataframe wurde hinzugefügt.

Verbesserungen¶

• README.md wurde aktualisiert und enthält nun Anweisungen zur Überprüfung von Paketsignaturen mit cosign.

Fehlerkorrekturen¶

• Es wurde ein Fehler im lokalen Testmodus behoben, der dazu führte, dass eine Spalte den Wert None enthielt, obwohl sie eigentlich 0 enthalten sollte.

• Ein Fehler in StructField.from_json wurde behoben, der verhinderte, dass TimestampTypes mit tzinfo korrekt geparst wurde.

• Ein Fehler in function date_format wurde behoben, der einen Fehler verursachte, wenn die Eingabespalte vom Typ Datum oder Zeitstempel war.

• Es wurde ein Fehler in DataFrame behoben, durch den Nullwerte in eine nicht-nullbare Spalte eingefügt werden konnten.

• Es wurde ein Fehler in den Funktionen replace und lit behoben, der bei der Übergabe von Column-Ausdrucksobjekten zu einem Fehler bei der Typ-Hinweis-Assertion führte.

• Ein Fehler in pandas_udf und pandas_udtf wurde behoben, bei dem Sitzungsparameter fälschlicherweise ignoriert wurden.

• Es wurde ein Fehler behoben, der einen falschen Typkonvertierungsfehler für Systemfunktionen auslöste, die über session.call aufgerufen wurden.

Snowpark Pandas API-Aktualisierungen¶