nuria

DELETE /percolator-queries

PUT percolator-queries
{
  "mappings": {
    "properties": {
      "search": {
        "properties": {
          "query": { 
            "type": "percolator" 

nuria

with base_data as (
--
select date_trunc('day', received_at) as received_at, count(*) as events_received  
 from some_com.performance_largest_contentful_paint where received_at > '2022-01-01' 
group by date_trunc('day', received_at) order by date_trunc('day', received_at)

)

select received_at, events_received , 
avg(events_received) over (partition by date_trunc('month',received_at)) as monthly_avg , 

nuria

select *,
	case
		when confirmed_at is not null and price_dollars > 0
		then row_number() over (
			partition by user_id, price_dollars > 0
			order by confirmed_at
		)
		else null
	end as user_enroll_rank,
	case

nuria

select 'alter table ' || table_schema || '.' || table_name || ' alter column experiment_assignments type varchar(65535);'
from svv_columns
where table_schema = 'some'
    and column_name = 'some'
    and character_maximum_length = 512;

nuria

#!/usr/bin/env python3

# usage: hny-column-cleanup.py [-h] -k API_KEY -d DATASET [-m {hidden,spammy}]
# Honeycomb Dataset Column Cleanup tool
# arguments:
#   -h, --help            show this help message and exit
#   -k API_KEY, --api-key API_KEY
#                         Honeycomb API key
#   -d DATASET, --dataset DATASET
#                         Honeycomb Dataset

nuria

with  base_data as (
    select received_at, date_trunc('day', received_at)::date as end_date ,
           date_add('day', -28, date_trunc('day', received_at))::date start_date, load_time
    from outschool_com.performance_largest_contentful_paint
    where
      received_at > date_add('day',-90, sysdate::date)
    and load_time > 0
    and load_time < 60000
    --order by md5('seed' || received_at)
    ),

nuria

   
#!/bin/bash
set -e

DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" >/dev/null && pwd )"
source ${DIR}/../../scripts/utils.sh

if [ ! -f ${DIR}/RedshiftJDBC4-1.2.20.1043.jar ]
then

nuria

/**
    Parses a Json Object.

    The object will be traversed, and each leaf node of the object will
    be keyed by a concatenated key made up of all parent keys.
**/
function MetricLogster(reporter) {

}

nuria

curl -X POST -H "Content-Type: application/vnd.kafka.jsonschema.v2+json" \
 -H "Accept: application/vnd.kafka.v2+json" \
 --data '{"value_schema_id":100101,   "records": [{"value": {"name": "testUser", "planet":"moon"} } ] }' \
   "http://localhost:8082/topics/rest-proxy-test"

nuria

from celery import Celery
from celery.signals import after_task_publish,task_success,task_prerun,task_postrun

# first argument, current module
app = Celery('tasks')
app.config_from_object('celeryconfig')

# To instantiate celery and import this module 
# do: celery -A task worker --loglevel=info
# after, once celery is running, instantiate a python console: