2 Risposte
- Più recenti
- Maggior numero di voti
- Maggior numero di commenti
1
I got it working as Athena query in Glue:
database = "my_database" table = "my_table" sql_query = "CREATE TABLE ..." athena_client = boto3.client("athena") response = athena_client.start_query_execution( QueryExecutionContext={"Database": database, "Catalog": table}, QueryString=sql_query, )
con risposta un anno fa
0
Hello,
It appears the table DDL being used in the question is not natively supported in Glue, hence the error.
To create a iceberg table in Glue, you can try the below:
# Example: Create an Iceberg table from a DataFrame
# and register the table to Glue Data Catalog
dataFrame.createOrReplaceTempView("tmp_<your_table_name>")
query = f"""
CREATE TABLE glue_catalog.<your_database_name>.<your_table_name>
USING iceberg
AS SELECT * FROM tmp_<your_table_name>
"""
spark.sql(query)
con risposta un anno fa
Contenuto pertinente
- AWS UFFICIALEAggiornata 2 anni fa
- AWS UFFICIALEAggiornata un anno fa
- AWS UFFICIALEAggiornata un anno fa