hitxiang

[profile xx-dev]
region = ap-northeast-1
aws_mfa_serial = arn:aws:iam::{master-aws-id}:mfa/zack_xxx
role_arn = arn:aws:iam::{dev-aws-id}:role/environment-admin
source_profile = default


export AWS_PROFILE=xx-dev

hitxiang

https://github.com/marclamberti/webinar-airflow-chart/blob/master/values.yaml

# create local k8s cluster
kind create cluster --name airflow-cluster --config kind-cluster.yaml

kubectl cluster-info 


kubect get nodes -o wide

hitxiang

# 让jupyter notebook中的一个cell同时有多个输出
from IPython.core.interactiveshell import InteractiveShell
InteractiveShell.ast_node_interactivity = "all"

hitxiang

The sequence of outgoing message:

• toAdmin/toApp
• persist outgoing messages in messgestore(fileStore in our case)
• increase sequence number of sender
• logging of messages
• send messages

The sequence of incoming message:

hitxiang

{"app_time":"2020-10-04T20:33:03.741Z","message":"parsed message: pos=88,lim=88,rem=0,offset=88,state=4 8=FIXT.1.1\u00019=65\u000135=0\u000134=2491\u000149=BO1\u000152=20201004-20:33:03.735\u000156=TAETF_BO1\u000110=120\u0001","logger_name":"quickfix.mina.message.FIXMessageDecoder","thread_name":"NioProcessor-30","level":"DEBUG"}
{"app_time":"2020-10-04T20:33:21.740Z","message":"parsed message: pos=97,lim=97,rem=0,offset=97,state=4 8=FIXT.1.1\u00019=74\u000135=1\u000134=2492\u000149=UniETF_BO1\u000152=20201004-20:33:21.735\u000156=TAETF_BO1\u0001112=TEST\u000110=140\u0001","logger_name":"quickfix.mina.message.FIXMessageDecoder","thread_name":"NioProcessor-30","level":"DEBUG"}
{"app_time":"2020-10-04T20:33:21.741Z","message":"==== TEST FIXT.1.1:TAETF_BO1->BO1:BackOffice AdminMessageReceived====","logger_name":"route8","thread_name":"QFJ Message Processor","level":"INFO"}
"\"Reference Handler\" 
   java.lang.Thread.State: RUNNABLE
        at java.base@11.0.2/java.lang.ref.Reference.waitForReferencePendingList(N

hitxiang

public class QuickfixjMessageJsonTransformer {
    private DataDictionary dataDictionary;
    public QuickfixjMessageJsonTransformer(){};
    public QuickfixjMessageJsonTransformer(DataDictionary dd) {
        this.dataDictionary = dd;
    }

    public String transform(Exchange exchange) {
        // camel message
        org.apache.camel.Message in = exchange.getIn();

hitxiang

#To be able to deploy the app as service in openshift we can follow various routes.

#I have follwed the binary build and deployment method..
https://access.redhat.com/documentation/en-us/red_hat_jboss_middleware_for_openshift/3/html/red_hat_java_s2i_for_openshift/get_started#source_to_image_s2i_build

#Other methods are also discussed in the recoommened guide above for being able to do deployment. for private source repository 
Image secret is need while doing s2i builds from the repo

#https://developers.redhat.com/blog/2017/02/23/getting-started-with-openshift-java-s2i/ provides other useful ways of deployment

hitxiang

#From cespi/php-5.3:cli-latest
From centos:centos6.9

RUN yum update -y \
    && yum install -y postfix cyrus-sasl-plain php rsyslog

COPY entrypoint.sh /usr/local/bin/
RUN chmod +x /usr/local/bin/entrypoint.sh
#COPY .env /.env
# 1, export environment variables

hitxiang

kubectl -n zack-app run zack-vault-test --image=golang --command -- sleep 10000000

kubectl -n zack-app get pods

# copy folder
kubectl -n zack-app cp vault-kubernetes-authenticator zack-vault-test-75998c55fd-dqkv8:/go

kubectl -n zack-app exec -it zack-vault-test-75998c55fd-dqkv8 -- /bin/bash

# Debug sample

hitxiang

package main

import (
        "encoding/json"
        "fmt"
        "net/http"
        "time"

        "github.com/hashicorp/vault/api"
        "github.com/hashicorp/vault/builtin/credential/aws"