mehd-io

-- ataching the remote database (268KB)
ATTACH 's3://us-prd-motherduck-open-datasets/content/duckdb-as-catalog/ducky_catalog.ddb';

SHOW all tables;

-- queries the data
FROM ducky_catalog.customers limit 5;

-- Listing views

mehd-io

CREATE MACRO add_one(value) AS (value + 1);

mehd-io

import logging
from datetime import datetime
import functools

# Setting up logging
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)

def measure_time(func):
    @functools.wraps(func)

mehd-io

#!/usr/bin/env bash
set -e

CDN="https://github.com/duckdb/duckdb/releases/download"
INSTALL_DIR="$HOME/.local/bin"

# Function to initialize platform specifics
initPlatform() {
    OS=$(uname -s | tr '[:upper:]' '[:lower:]')
    ARCH=$(uname -m)

mehd-io

#!/bin/bash
# A simple script for converting files between CSV and Parquet formats using DuckDB. Requires DuckDB installation.

convert_file() {
    local input_file="$1"
    local output_extension="$2"

    # Extracting the filename without extension
    local base_name=$(basename -- "$input_file")
    local name="${base_name%.*}"

mehd-io

-- Install httpfs extension
INSTALL httpfs;
LOAD httpfs;
-- Install Scrooge extension https://github.com/pdet/Scrooge-McDuck
-- NOTE : You need to start DuckDB with `-unsigned` flag to authorized to install & load 3rd party extension
SET custom_extension_repository='scrooge-duckdb.s3.us-west-2.amazonaws.com/scrooge/s3_deploy';
INSTALL scrooge;
LOAD scrooge;
-- Example of query 
FROM yahoo_finance("^GSPC", "2023-02-01", "2023-02-04", "1d");

mehd-io

#!/bin/bash
# You can put this in your .bashrc or .zshrc
function csv_to_parquet() {
    file_path="$1"
    duckdb -c "COPY (SELECT * FROM read_csv_auto('$file_path')) TO '${file_path%.*}.parquet' (FORMAT PARQUET);"
}

mehd-io

from pathlib import Path

import pytest
import tftest
from google.auth.transport.requests import AuthorizedSession

from .cloud_run_client import (
    get_auth_session,
    get_service_account_file_path,
    get_token_credentials_from_service_account,

mehd-io

import json

import pytest
from google.auth.transport.requests import AuthorizedSession

from .cloud_run_client import request_wrapper


@pytest.mark.integration
def test_health_check(auth_session: AuthorizedSession):

mehd-io

import pytest
import tftest
from pathlib import Path


@pytest.fixture
def plan():
    file_path = Path(__file__).resolve()
    base_dir = file_path.parent.parent.parent.absolute()
    tf = tftest.TerraformTest(tfdir="terraform", basedir=base_dir)