hongbo-miao

```sh
[Worker-0b87c1d131f888840] No sanity checks script found. Ignoring.
[Worker-0b87c1d131f888840] Waiting for resolving bootstrap servers address ...
[Worker-0b87c1d131f888840] Successfully resolved bootstrap servers address.
[Worker-0b87c1d131f888840] Starting MSK Connect...
[Worker-0b87c1d131f888840] [2024-07-10 20:45:15,092] INFO WorkerInfo values:
[Worker-0b87c1d131f888840] 	jvm.args = JVM_ARGS
[Worker-0b87c1d131f888840] 	jvm.spec = Amazon.com Inc., OpenJDK 64-Bit Server VM, 11.0.22, 11.0.22+7-LTS
[Worker-0b87c1d131f888840] 	jvm.classpath = CLASSPATH
[Worker-0b87c1d131f888840] 	os.spec = Linux, amd64, 5.10.215-203.850.amzn2.x86_64

hongbo-miao

{"label":"code lines","message":"219.1k","schemaVersion":1,"color":"blue","labelColor":"gray"}

hongbo-miao

#if defined(ESP32)
#include <WiFiMulti.h>
WiFiMulti wifiMulti;
#define DEVICE "ESP32"
#elif defined(ESP8266)
#include <ESP8266WiFiMulti.h>
ESP8266WiFiMulti wifiMulti;
#define DEVICE "ESP8266"
#endif

hongbo-miao

{
    "name": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
    "error_count": 3,
    "groups": [
        "Common",
        "Transforms",
        "Predicates",
        "Error Handling",
        "Transforms: unwrap",
        "Transforms: key",

hongbo-miao

version: "3.8"
services:
  # When scaling the opal-server to multiple nodes and/or multiple workers, we use
  # a *broadcast* channel to sync between all the instances of opal-server.
  # Under the hood, this channel is implemented by encode/broadcaster (see link below).
  # At the moment, the broadcast channel can be either: postgresdb, redis or kafka.
  # The format of the broadcaster URI string (the one we pass to opal server as `OPAL_BROADCAST_URI`) is specified here:
  # https://github.com/encode/broadcaster#available-backends
  broadcast_channel:
    image: postgres:alpine

hongbo-miao

"""
you may run this example with uvicorn, by using this command:

uvicorn opalogger:app --reload
"""

import gzip
from typing import Callable, List

from fastapi import Body, FastAPI, Request, Response

hongbo-miao

// Reference: http://stackoverflow.com/questions/4822471/count-number-of-lines-in-a-git-repository

$ git ls-files | xargs wc -l

hongbo-miao

"""
Minimal character-level Vanilla RNN model. Written by Andrej Karpathy (@karpathy)
BSD License
"""
import numpy as np

# data I/O
data = open('input.txt', 'r').read() # should be simple plain text file
chars = list(set(data))
data_size, vocab_size = len(data), len(chars)

hongbo-miao

from math import sqrt

import torch
from tqdm import tqdm
import matplotlib.pyplot as plt
import networkx as nx
from torch_geometric.nn import MessagePassing
from torch_geometric.data import Data
from torch_geometric.utils import k_hop_subgraph, to_networkx
import numpy as np

hongbo-miao

Version 2/18/2021

The script is for IT employees who work in Shanghai office.

Feel free to contact me if you have any questions.

How to use the script?

Step 1