wpcarro

import React from "react";
import { useForm } from "react-hook-form";
import { z } from "zod";
import { zodResolver } from "@hookform/resolvers/zod";
import DimensionID from "lib/quality/DimensionID";


////////////////////////////////////////////////////////////////////////////////
// Main
////////////////////////////////////////////////////////////////////////////////

wpcarro

input:
  sql_raw:
    driver: mssql
    dsn: sqlserver://${USER}:${PASS}@some.place.com
    query: |
      select * from blah

output:
  file:
    path: '/tmp/stuff/${! json("filename") }'

wpcarro

{
  "series": [
    {
      "metric": "corp.service.heartbeat",
      "type": 3,
      "points": [
        {
          "timestamp": timestamp_unix(),
          "value": 1,
        }

wpcarro

input:
  file:
    paths:
      - /tmp/versions.json
    codec: all-bytes
  processors:
    - jq:
        query: '.[] | select( .Name | contains("Needle") ) | {"name": .Name, "key": .Key}'
    - unarchive:
        format: json_array

wpcarro

- cmd: man passwd
  when: 1653257918
- cmd: sudo passwd
  when: 1653257918
- cmd: passwd
  when: 1653257918
- cmd: sudo vim /etc/nixos/configuration.nix
  when: 1653257918

wpcarro

http:
  enabled: false

input:
  file:
    paths:
      - /tmp/errors.json
    codec: all-bytes
  processors:
    - unarchive:

wpcarro

// Convert a sorting expressions (e.g. "Outflow DESC; Date ASC; Category ASC")
// into a function that can be passed to Array.prototype.sort.
function compileSort(expr) {
    if (expr === '') {
        return function(x, y) { return 0; };
     }
    return expr.split(/\s*;\s*/).reverse().reduce((acc, x) => {
        const [k, dir] = x.split(/\s+/);
        if (dir === 'ASC') {
            return function(x, y) {

wpcarro

apiVersion: batch/v1
kind: Job
metadata:
  name: foo-command
spec:
  ttlSecondsAfterFinished: 60
  template:
    spec:
      containers:
      - name: foo-command

wpcarro

input:
  label: ynab_api
  generate:
    mapping: root = ""
    interval: '@every 5m'
  processors:
    - cache:
        operator: get
        resource: pagination
        key: latest

wpcarro

# Proof-of-concept caching with benthos:
#   - read from cache (with default on first run)
#   - log value
#   - write random value to cache
#   - repeat

input:
  generate:
    mapping: root = ""
  processors: