-
Notifications
You must be signed in to change notification settings - Fork 892
/
start.sh
executable file
·156 lines (116 loc) · 7.53 KB
/
start.sh
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
#!/bin/bash
#set -e
PRJ_DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" >/dev/null && pwd )"
UTILS_DIR="${PRJ_DIR}/utils"
TMP_FOLDER="${PRJ_DIR}/tmp"
TFS_PATH="${PRJ_DIR}/terraform/aws"
STATE_FILE_PATH="${TFS_PATH}/terraform.tfstate"
LOGS_FOLDER="${PRJ_DIR}/logs"
LOG_FILE_PATH="${LOGS_FOLDER}/start.log"
export EXAMPLE="streaming-pacman"
function init_vars_from_tf_output() {
ENVIRONMENT_ID=$(terraform output -json -state=${STATE_FILE_PATH} | jq ".environment_id.value" -r)
KAFKA_CLUSTER_ID=$(terraform output -json -state=${STATE_FILE_PATH} | jq ".confluent_kafka_cluster_id.value" -r)
KSQLDB_CLUSTER_ID=$(terraform output -json -state=${STATE_FILE_PATH} | jq ".confluent_ksql_cluster_id.value" -r)
KSQLDB_ENDPOINT=$(terraform output -json -state=${STATE_FILE_PATH} | jq ".confluent_ksql_cluster_api_endpoint.value" -r)
KSQLDB_CLUSTER_SERVICE_ACCOUNT_ID=$(terraform output -json -state=${STATE_FILE_PATH} | jq ".confluent_ksql_cluster_service_account_id.value" -r)
KSQLDB_CLUSTER_API_KEY=$(terraform output -json -state=${STATE_FILE_PATH} | jq ".confluent_ksql_cluster_api_key.value" -r)
KSQLDB_CLUSTER_API_SECRET=$(terraform output -json -state=${STATE_FILE_PATH} | jq ".confluent_ksql_cluster_api_secret.value" -r)
PACMAN_URL=$(terraform output -json -state=${STATE_FILE_PATH} | jq ".Pacman.value" -r)
}
function create_infra_with_tf (){
# DELTA_CONFIGS_DIR=delta_configs
# source $DELTA_CONFIGS_DIR/env.delta
# create_tfvars_file
cd $TFS_PATH
terraform init
terraform apply --auto-approve
}
function check_mvn() {
if [[ $(type mvn 2>&1) =~ "not found" ]]; then
echo "'mvn' is not found. Install 'mvn' and try again"
exit 1
fi
return 0
}
function validate_pre_reqs {
ccloud::validate_version_cli 2.38.0 \
&& print_pass "confluent CLI version ok" \
|| exit 1
ccloud::validate_logged_in_cli \
&& print_pass "logged into confluent CLI" \
|| exit 1
check_jq \
&& print_pass "jq found" \
|| exit 1
check_mvn \
&& print_pass "mvn found" \
|| exit 1
}
function create_ksqldb_app {
init_vars_from_tf_output
MAX_WAIT=720
echo "Waiting up to $MAX_WAIT seconds for Confluent Cloud ksqlDB cluster $KSQLDB_ENDPOINT to be UP"
confluent environment use $ENVIRONMENT_ID
#retry $MAX_WAIT ccloud::validate_ccloud_ksqldb_endpoint_ready $KSQLDB_ENDPOINT || exit 1
#################################################################
# Confluent Cloud ksqlDB application
#################################################################
KSQLDB_BASIC_AUTH_USER_INFO="${KSQLDB_CLUSTER_API_KEY}:${KSQLDB_CLUSTER_API_SECRET}"
cd $PRJ_DIR
export KSQLDB_ENDPOINT=$KSQLDB_ENDPOINT
export KSQLDB_BASIC_AUTH_USER_INFO=$KSQLDB_BASIC_AUTH_USER_INFO
./create_ksqldb_app.sh || exit 1
}
function start_demo {
# Source demo-specific configurations
source $PRJ_DIR/config/demo.cfg
source $UTILS_DIR/demo_helper.sh
validate_pre_reqs
ccloud::prompt_continue_ccloud_demo || exit 1
create_infra_with_tf
create_ksqldb_app
welcome_screen
}
#http://patorjk.com/software/taag/#p=display&f=ANSI%20Regular&t=pacman%20demo%0A%20Confluent%20
function welcome_screen {
echo " ";
echo " ";
echo " ██████ █████ ██████ ███ ███ █████ ███ ██ ██████ ███████ ███ ███ ██████ ";
echo " ██ ██ ██ ██ ██ ████ ████ ██ ██ ████ ██ ██ ██ ██ ████ ████ ██ ██ ";
echo " ██████ ███████ ██ ██ ████ ██ ███████ ██ ██ ██ ██ ██ █████ ██ ████ ██ ██ ██ ";
echo " ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ";
echo " ██ ██ ██ ██████ ██ ██ ██ ██ ██ ████ ██████ ███████ ██ ██ ██████ ";
echo " ";
echo " ";
echo " ██████ ██████ ███ ██ ███████ ██ ██ ██ ███████ ███ ██ ████████ ";
echo " ██ ██ ██ ████ ██ ██ ██ ██ ██ ██ ████ ██ ██ ";
echo " ██ ██ ██ ██ ██ ██ █████ ██ ██ ██ █████ ██ ██ ██ ██ ";
echo " ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ██ ";
echo " ██████ ██████ ██ ████ ██ ███████ ██████ ███████ ██ ████ ██ ";
echo " ";
echo " ";
echo " ================================================. ";
echo " .-. .-. .--. | ";
echo " | OO| | OO| / _.-' .-. .-. .-. .''. | ";
echo " | | | | \ '-. '-' '-' '-' '..' | ";
echo " '^^^' '^^^' '--' | ";
echo " ===============. .-. .================. .-. | ";
echo " | | | | | '-' | ";
echo " | | | | | | ";
echo " | ':-:' | | .-. | ";
echo " l42 | '-' | | '-' | ";
echo " ===============' '================' | ";
echo
echo "**************************************************************************************************";
echo
echo
echo "Handy links: "
echo " - PLAY HERE --> ${PACMAN_URL} ";
echo
echo "Cloud resources are provisioned and accruing charges. To destroy this demo and associated resources run ->"
echo " ./stop.sh"
echo
}
mkdir $LOGS_FOLDER
start_demo 2>&1 | tee -a $LOG_FILE_PATH