s-chb

CREATE STREAM PROCESS_LOGPICKR
  WITH (
   KAFKA_TOPIC='process_logpickr',
   VALUE_FORMAT='DELIMITED'
  ) AS
    SELECT
      PROC_DEF_ID_, 
      EXECUTION_ID_, 
      NAME_ ,
      START_TIME, 

s-chb

CREATE STREAM transition
  WITH (
   TIMESTAMP='START_TIME_,END_TIME_',
   KAFKA_TOPIC='transition',
   VALUE_FORMAT='DELIMITED'
  ) AS
    SELECT
      PROC_DEF_ID_, 
      EXECUTION_ID_, 
      NAME_ ,

s-chb

sudo systemctl stop node_exporter &&
sudo systemctl start node_exporter &&
sudo systemctl stop prometheus &&
sudo systemctl start prometheus &&
sudo systemctl stop alertmanager &&
sudo systemctl start alertmanager

s-chb

---
version: '2'
services:
  zookeeper:
    image: confluentinc/cp-zookeeper:5.5.1
    hostname: zookeeper
    container_name: zookeeper
    ports:
      - "2181:2181"
    environment:

s-chb

CREATE SOURCE CONNECTOR CSVSpoolDir WITH (
  'connector.class'         = 'com.github.jcustenborder.kafka.connect.spooldir.SpoolDirCsvSourceConnector',
  'finished.path'	           =	'/tmp/finished',
  'input.path'	             =	'/tmp/data',
  'error.path'               =	'/tmp/error',
  'input.file.pattern'       =	'csv-spooldir-source.csv',
  'topic'	             =	'spooldir-csv-topic',
  'schema.generation.enabled' = 'true'
);

s-chb

CREATE SOURCE CONNECTOR JsonSpoolDir WITH (
  'tasks.max' = '1',
  'connector.class' = 'com.github.jcustenborder.kafka.connect.spooldir.SpoolDirJsonSourceConnector',
  'input.path' = '/tmp/data',
  'input.file.pattern' = 'json-spooldir-source.json',
  'error.path' = '/tmp/error',
  'finished.path' = '/tmp/finished',
  'halt.on.error' = 'false',
  'topic' = 'spooldir-json-topic',
  'schema.generation.enabled' = 'true'

s-chb

#!/bin/sh

set -ex

if [ `id -u` -ne 0 ]; then
     sudo $0
    exit 0
fi

## your custom code below

s-chb

source variable.sh
packer build template.json

s-chb

{    
    "variables": {
        "os_username": "{{env `OS_USERNAME`}}",
        "os_password": "{{env `OS_PASSWORD`}}",
        "os_auth_url": "{{env `OS_AUTH_URL`}}",
        "os_region_name": "{{env `OS_REGION_NAME`}}",
        "os_tenant_name": "{{env `OS_TENANT_NAME`}}",
        "ssh_username": "{{env `SSH_USERNAME`}}",
        "os_domaine_name": "{{env `OS_USER_DOMAIN_NAME`}}",
        "instance_name": "{{env `INSTANCE_NAME`}}",

s-chb

#!/bin/bash
export OS_USERNAME=xxx
echo "Please enter your OpenStack Password: "
read -sr OS_PASSWORD_INPUT
export OS_PASSWORD=$OS_PASSWORD_INPUT
export OS_AUTH_URL="https://iam.xxx.com/v3"
export OS_REGION_NAME=xxx
export OS_TENANT_NAME=xxx
export OS_USER_DOMAIN_NAME=xxx
export SSH_USERNAME=xxx