Geunho Kim geunho

## cnn.sh
echo cons | nc localhost 2181

## bash_date_loop.sh
start=20220101
end=20221014

while ! [[ $start > $end ]]; do
	start=$(date -d "$start + 1 day" +%Y%m%d)
	day=$(date -d "$start" +%d)
	# 예시. 매월 1일은 처리 대상에서 제외
	if [ $day != 01 ]; then
	  echo $start
	  ## DO YOUR WORK

## citus_shard_to_node_map.sql
SELECT s.shardid id, shardminvalue min, shardmaxvalue MAX, p.nodename
FROM pg_dist_shard s
LEFT JOIN pg_dist_shard_placement p
  ON s.shardid = p.shardid
WHERE logicalrelid = $TABLE_NAME::regclass;

## md5_digest.scala
import rg.apache.commons.codec.digest.DigestUtils

val origin = "test text"
val hash = DigestUtils.md5Hex(origin)

println(hash)

## pg_stat_activity.sql
select pid,
       usename,
       pg_blocking_pids(pid) as blocked_by,
       query as blocked_query
from pg_stat_activity

## base64_encode_decode.scala
val contents = "문자열 base64 인코딩/디코딩 테스트."
val encoded = java.util.Base64.getEncoder.encode(contents.getBytes)
val decoded = java.util.Base64.getDecoder.decode(encoded)
val result = new String(decoded)
assert(contents == result)

## string_to_hex.scala
def string2hex(str: String): String = str.toSeq.map(_.toInt.toHexString).mkString(" ")

## offset_rewind.sh
./kafka-consumer-groups \
--bootstrap-server $BROKER_LIST \
--group $CONSUMER_GROUP \
--topic $TOPIC \
--reset-offsets \
--to-datetime 2021-04-20T15:00:00.000 \
--execute

## find_tips.sh
# 특정 단어가 포함된 파일 찾기
find $FILE_PATH_TO_FIND -type f -print | xargs grep $WORD_TO_FIND

## kubectl_cheat_sheet.sh
# 이미지 확인을 위해 임시로 /bin/bash pod 띄우기
kubectl run $POD_NAME --rm -i --tty --restart=Never --image=$IMAGE:$TAG --command -- /bin/bash

# pod 상태 변경시 출력하기 - OOMKill 등 확인시 사용
kubectl get pod -w

# pvc 용량 증설 (변경 저장 후 물고있는 pod 재시작해야함)
kubectl edit pvc $PVC_NAME

# statefulset pod 재시작
	start=20220101
	end=20221014

	while ! [[ $start > $end ]]; do
	start=$(date -d "$start + 1 day" +%Y%m%d)
	day=$(date -d "$start" +%d)
	# 예시. 매월 1일은 처리 대상에서 제외
	if [ $day != 01 ]; then
	echo $start
	## DO YOUR WORK
	SELECT s.shardid id, shardminvalue min, shardmaxvalue MAX, p.nodename
	FROM pg_dist_shard s
	LEFT JOIN pg_dist_shard_placement p
	ON s.shardid = p.shardid
	WHERE logicalrelid = $TABLE_NAME::regclass;
	import rg.apache.commons.codec.digest.DigestUtils

	val origin = "test text"
	val hash = DigestUtils.md5Hex(origin)

	println(hash)
	select pid,
	usename,
	pg_blocking_pids(pid) as blocked_by,
	query as blocked_query
	from pg_stat_activity
	val contents = "문자열 base64 인코딩/디코딩 테스트."
	val encoded = java.util.Base64.getEncoder.encode(contents.getBytes)
	val decoded = java.util.Base64.getDecoder.decode(encoded)
	val result = new String(decoded)
	assert(contents == result)
	./kafka-consumer-groups \
	--bootstrap-server $BROKER_LIST \
	--group $CONSUMER_GROUP \
	--topic $TOPIC \
	--reset-offsets \
	--to-datetime 2021-04-20T15:00:00.000 \
	--execute
	# 특정 단어가 포함된 파일 찾기
	find $FILE_PATH_TO_FIND -type f -print \| xargs grep $WORD_TO_FIND
	# 이미지 확인을 위해 임시로 /bin/bash pod 띄우기
	kubectl run $POD_NAME --rm -i --tty --restart=Never --image=$IMAGE:$TAG --command -- /bin/bash

	# pod 상태 변경시 출력하기 - OOMKill 등 확인시 사용
	kubectl get pod -w

	# pvc 용량 증설 (변경 저장 후 물고있는 pod 재시작해야함)
	kubectl edit pvc $PVC_NAME

	# statefulset pod 재시작