Error Ducklake: Writing parquet file fails.

export async function main(x: string) {
  await wmill.writeS3File('s3:///datalake/main/states2/ducklake-019980aa-6391-7047-a139-e01c8fcdb657.parquet', 'hello world')
}

export async function main(x: string) {
  await wmill.writeS3File('s3:///datalake/main/states2/ducklake-019980aa-6391-7047-a139-e01c8fcdb657.parquet', 'hello world')
}

import { PutObjectCommand, S3Client } from "@aws-sdk/client-s3"

export async function main() {
  const baseUrl = process.env["WM_BASE_URL"]
  const s3 = new S3Client({
    region: "us-west-1",
    forcePathStyle: true,
    endpoint: baseUrl + '/api/w/' + process.env["WM_WORKSPACE"] + '/s3_proxy',
    credentials: {
      accessKeyId: process.env["WM_TOKEN"].split('.')[0] + '.' + process.env["WM_TOKEN"].split('.')[1],
      secretAccessKey: process.env["WM_TOKEN"].split('.')[2],
    },
  });
  const command = new PutObjectCommand({
    Bucket: "_default_",
    Key: "helloworld.txt",
    Body: "hello world",
  });

  try {
    const response = await s3.send(command);
    console.log("File uploaded successfully:", response);
  } catch (err) {
    console.error("RAW RESPONSE", (err as any).$response);
    console.error("Error uploading:", err);
  }
}

import { PutObjectCommand, S3Client } from "@aws-sdk/client-s3"

export async function main() {
  const baseUrl = process.env["WM_BASE_URL"]
  const s3 = new S3Client({
    region: "us-west-1",
    forcePathStyle: true,
    endpoint: baseUrl + '/api/w/' + process.env["WM_WORKSPACE"] + '/s3_proxy',
    credentials: {
      accessKeyId: process.env["WM_TOKEN"].split('.')[0] + '.' + process.env["WM_TOKEN"].split('.')[1],
      secretAccessKey: process.env["WM_TOKEN"].split('.')[2],
    },
  });
  const command = new PutObjectCommand({
    Bucket: "_default_",
    Key: "helloworld.txt",
    Body: "hello world",
  });

  try {
    const response = await s3.send(command);
    console.log("File uploaded successfully:", response);
  } catch (err) {
    console.error("RAW RESPONSE", (err as any).$response);
    console.error("Error uploading:", err);
  }
}

import os
import boto3
from botocore.exceptions import ClientError


def main():
    base_url = os.environ["BASE_INTERNAL_URL"] or os.environ["WM_BASE_URL"]
    token = os.environ["WM_TOKEN"]
    workspace = os.environ["WM_WORKSPACE"]

    # Split the token
    token_parts = token.split(".")
    access_key_id = f"{token_parts[0]}.{token_parts[1]}"
    secret_access_key = token_parts[2]

    # Create S3 client
    s3 = boto3.client(
        "s3",
        region_name="us-west-1",
        endpoint_url=f"{base_url}/api/w/{workspace}/s3_proxy",
        aws_access_key_id=access_key_id,
        aws_secret_access_key=secret_access_key,
        config=boto3.session.Config(s3={"addressing_style": "path"}),
    )

    try:
        # Upload file
        response = s3.put_object(
            Bucket="_default_", Key="helloworld.txt", Body="hello world"
        )
        print("File uploaded successfully:", response)
    except ClientError as err:
        print("Error uploading:", err)
        print("Response:", err.response)


if __name__ == "__main__":
    main()

import os
import boto3
from botocore.exceptions import ClientError


def main():
    base_url = os.environ["BASE_INTERNAL_URL"] or os.environ["WM_BASE_URL"]
    token = os.environ["WM_TOKEN"]
    workspace = os.environ["WM_WORKSPACE"]

    # Split the token
    token_parts = token.split(".")
    access_key_id = f"{token_parts[0]}.{token_parts[1]}"
    secret_access_key = token_parts[2]

    # Create S3 client
    s3 = boto3.client(
        "s3",
        region_name="us-west-1",
        endpoint_url=f"{base_url}/api/w/{workspace}/s3_proxy",
        aws_access_key_id=access_key_id,
        aws_secret_access_key=secret_access_key,
        config=boto3.session.Config(s3={"addressing_style": "path"}),
    )

    try:
        # Upload file
        response = s3.put_object(
            Bucket="_default_", Key="helloworld.txt", Body="hello world"
        )
        print("File uploaded successfully:", response)
    except ClientError as err:
        print("Error uploading:", err)
        print("Response:", err.response)


if __name__ == "__main__":
    main()