esemeniuc

import "array"
 
array.from(rows: [
  {_time: 2021-01-01T00:00:00Z, _value: "foo"},
  {_time: 2020-01-02T00:00:00Z, _value: "bar"}
])

esemeniuc

cat file.csv | sqlite3 demo.db ".import --csv '|cat -' mytable"; sqlite3 demo.db

esemeniuc

use std::thread::sleep;
use std::time::{Duration, Instant};
use redis::{AsyncCommands, ConnectionLike, RedisResult};

use tokio::time::timeout;

use futures::StreamExt;
use futures_util::Stream;

/* Cargo.toml

esemeniuc

Generate expiring certs

#!/bin/bash

# Generate some test certificates which are used by the regression test suite:
#
#   tests/tls/ca.{crt,key}          Self signed CA certificate.
#   tests/tls/redis.{crt,key}       A certificate with no key usage/policy restrictions.
#   tests/tls/client.{crt,key}      A certificate restricted for SSL client usage.
#   tests/tls/server.{crt,key}      A certificate restricted for SSL server usage.

esemeniuc

local keys = redis.call('KEYS', ARGV[1]);
if next(keys) == nil then return keys end;
local chunk_size = 4096; -- must be under 8k, see https://github.com/nhibernate/NHibernate-Caches/issues/62
local n = #keys;
local out = {};

for i=1,n,chunk_size do
    local unpack_start = i;
    local unpack_end = math.min(n, i + chunk_size - 1);
    local vals = redis.call('MGET', unpack(keys, unpack_start, unpack_end));

esemeniuc

Subscribe to any acount changes to Pyth SOL/USDC account (H6AR...QJEG):

This requires websocat - `brew install websocat`
```bash
echo '{"id":1,"jsonrpc":"2.0","method":"accountSubscribe","params":["H6ARHf6YXhGYeQfUzQNGk6rDNnLBQKrenN712K4AQJEG",{"encoding": "jsonParsed"}]}' | websocat --no-close "wss://internal.ny.mainnet.rpc.jito.wtf/?access-token=XYZ"
```

Output
```
{"jsonrpc":"2.0","method":"accountNotification","params":{"result":{"context":{"slot":240142003},"value":{"lamports":23942400,"data":["1MOyoQIAAAADAAAA8AwAAAEAAAD4////GgAAABcAAAC0RlAOAAAAALNGUA4AAAAAGAudTAIAAAB/ZvSRAAAAAJ08zJMAAAAAFUKKAAAAAAAc++qFAAAAAJ08zJMAAAAAUNSYZQAAAAADAAAAAAAAAIqwPP8YRKuXXc3RaDAgwFmfxTkrby4S1d1hW8wsLm0IAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAACzRlAOAAAAAHT4GUsCAAAA6daTAAAAAABP1JhlAAAAAHT4GUsCAAAA6C6NAAAAAAABAAAAAAAAALRGUA4AAAAAB/LLOf2wKdxReE0o7xeRHZfBppyFcjobYlWzQlNDrXUNzhRLAgAAAKBnWgMAAAAAAQAAAAAAAACeRlAOAAAAAA3OFEsCAAAAoGdaAwAAAAABAAAAAAAAAJ5GUA4AAAAAnz6le9QJugDEDZKuVxNBwn48L37frOHCSlGxoVwxsregsyJLAgAAAAJjkgMAAAAAAQAAA

esemeniuc

    fn amain() {
        use std::{
            future::poll_fn,
            pin::Pin,
            task::{Context, Poll},
        };

        use tokio::sync::mpsc;
        let (tx, mut rx) = mpsc::channel(100);

esemeniuc

/// See https://w3c.github.io/trace-context-binary/#de-serialization-of-traceparent
fn parse_traceparent(bytes: &[u8]) -> Result<SpanContext, &'static str> {
    if bytes.len() != 29 {
        return Err("Invalid traceparent length. Must be 29 bytes.");
    }

    if bytes[0] != 0 {
        return Err("Unsupported traceparent version.");
    }
    if bytes[1] != 0 {

esemeniuc

// dict
let mut dict_file =
    std::fs::File::open("dictionaryFile").unwrap();
let mut dict = Vec::new();
dict_file.read_to_end(&mut dict).unwrap();

// compress
let mut enc_buf = [0; 1_000_000];
let encoder_dict = zstd::dict::EncoderDictionary::copy(&dict, 0);
let mut compressor =

esemeniuc

see https://github.com/esemeniuc/influxdb/pull/1/files Build with docker build -t influxdb:3-core-test --build-arg PBS_DATE=20250106 --build-arg PBS_VERSION=3.11.11 --build-arg PBS_TARGET=x86_64-unknown-linux-gnu .

tags and fields compatibility with v1:

• you can add and omit tags like before, all tags are strings (no need to worry about type change)
• you can add and omit fields like before, but cannot change a field type (ie string to i64)
• you cannot convert tag to field and vice-versa

Setup: