maratori

# This file is licensed under the terms of the MIT license https://opensource.org/license/mit
# Copyright (c) 2021-2025 Marat Reymers

## Golden config for golangci-lint v2.1.6
#
# This is the best config for golangci-lint based on my experience and opinion.
# It is very strict, but not extremely strict.
# Feel free to adapt it to suit your needs.
# If this config helps you, please consider keeping a link to this file (see the next comment).

rawc0der

#!/bin/bash
# Small utility function based on yq to extract openAPIV3Schema from CRD
# example:  crd2jsonschema.sh ./crd-alertmanager.yaml
set -e

function crd2jsonschema() {
    set -e
    local xkgroup="x-kubernetes-group-version-kind"
    local document="$1"
    local openAPIV3Schema=$(mktemp -u)

Ogaday

Prefect on Dask on K8s

Intro

A "Hello, world!" Prefect flow running on an ephemeral Dask Cluster on Kubernetes.

The Prefect Core docs suggest running flows on a Dask cluster via Dask Distributed and an article from the MET Office Informatics Lab demonstrates running an adaptive Dask cluster on k8s. This example is inspired by those sources, as well as the respective docs for the technologies used.

Running Instructions

voluntas

負荷試験コトハジメ

更新:	2021-05-23
作者:	@voluntas
バージョン:	2021.1
URL:	https://voluntas.github.io/

hajimeni

# stdlib
import re
import copy

# 3rd party
import requests

# project
from checks import AgentCheck

hiroyuki-sato

注意: まだ書きかけです。

プラグインを開発する

このガイドでは、Embulkのプラグインを開発する方法を説明します。

新しいプラグインを作ることで、新規のクラウドサービスからデータを取得したり、新しいデータウェアハウスシステムにデータを出力できるようになります。

入力から出力まで全てのプラグインを開発する必要はありません。Embulkには既に多くのプラグインが提供されています。既存のプラグインでは足りない部分だけを開発すれば良いのです。

sonots

<source>
  type in_tail
  # ...
  tag raw.eventlog
</source>

<match raw.**>
  type forward
  log_level "#{ENV['DEBUG'] ? 'debug' : 'info'}"

bloodredsun

package com.brs;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * Simple class that we use to trigger a log statement.
 */
public class ExampleThatLogs {

abevoelker

# project_name/pipelines.py

from scrapy import signals
from scrapy.utils.serialize import ScrapyJSONEncoder
from scrapy.xlib.pydispatch import dispatcher

from carrot.connection import BrokerConnection
from carrot.messaging import Publisher

from twisted.internet.threads import deferToThread

jmervine

package main

import (
  "fmt"
  "log"
  "net/http"
)

func Log(handler http.Handler) http.Handler {
  return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {