Gorina Homework-9

README.md

@@ -1,13 +1,10 @@
-# Практика к занятию по теме "Service mesh на примере Istio"
+# Домашняя работа к занятию по теме "Service mesh на примере Istio"
 
 ## Зависимости
 
-Для выполнения задания вам потребуется установить зависимости:
+Для выполнения задания вам потребуется скачать релиз istio со всеми необходимыми зависимостями внутри:
 
-- [Minikube 1.13.1](https://github.com/kubernetes/minikube/releases/tag/v1.13.1)
-- [Kubectl 0.19.2](https://github.com/kubernetes/kubectl/releases/tag/v0.19.2)
-- [Istioctl 1.7.3](https://github.com/istio/istio/releases/tag/1.9.0)
-- [Heml 3.3.4](https://github.com/helm/helm/releases/tag/v3.3.4)
+https://github.com/istio/istio/releases/tag/1.14.3
 
 ## Содержание
 
@@ -25,64 +22,60 @@
 - Настроить балансировку трафика между версиями приложения на уровне Gateway 50% на 50%
 - Сделать снимок экрана с картой сервисов в Kiali с примеров вызова двух версии сервиса
 
-![Пример карты сервисов с балансировкой трафика между версиями](kiali-map-example.png)
-
 ## Инструкция по выполнению задания
 
 - Сделать форк этого репозитория на Github
 - Выполнить задание в отдельной ветке
 - Создать Pull request с изменениями в этот репозиторий
 
-## Лайфхаки по выполнению задания
-
-Для выполнения задания вы можете воспользоваться [материалами демо](https://github.com/izhigalko/otus-demo-istio).
-
----
-
-Спецификацию IstioOperator можно посмотреть
-[в документации Istio](https://istio.io/latest/docs/reference/config/istio.operator.v1alpha1/#IstioOperatorSpec)
-или можно посмотреть [исходники манифестов, исполняемых оператором](https://github.com/istio/istio/tree/master/manifests).
-
----
-
-Если вы хотите изменить текущую конфигурацию Istio,
-достаточно применить манифест с указанием конфигурации:
-
-```shell script
-kubectl apply -f istio/istio-manifest.yaml
-```
-
----
-
-Для выключения шифрования между прокси, нужно применить настройку:
-
-```shell script
-kubectl apply -f istio/defaults.yaml
-```
-
----
-
-Для доступа к какому-либо сервису с хоста можно использовать тип NodePort в сервисе:
-
-```yaml
----
-apiVersion: v1
-kind: Service
-metadata:
-  name: test
-  namespace: default
-spec:
-  type: NodePort
-  ports:
-    - port: 80
-      nodePort: 32080
-      targetPort: 8080
-  selector:
-    app: test
-```
-
-Использовать специальную команду для доступа к сервису:
-
-```yaml
-minikube service -n <namespace> <service>
-```
+## Для запуска проекта потребуется
+
+- Разворачиваем minikube в Docker Desctop под Windows
+
+- После скачивания релиза Istio заходим в папку istio-1.14.3-win\istio-1.14.3\bin и прописываем istioctl в path 
+
+- Устанавливаем istio командой: 
+  ~~~~
+  istioctl install
+  ~~~~
+
+- Переходим в папку со скаченным релизом: **cd АДРЕС_ДО_РЕЛИЗА\istio-1.14.3-win\istio-1.14.3**
+
+- Устанавливаем аддоны: 
+  ~~~~
+  kubectl apply -f samples/addons
+  ~~~~
+
+- Проверяем, что все корректно работает
+
+  ~~~~
+  kubectl get services -n istio-system
+  ~~~~
+
+  ~~~~
+  kubectl get services -n istio-system
+  ~~~~
+
+- Пробрасываем все необходимые порты, например kiali
+  ~~~~
+  kubectl port-forward service/kiali   20001:20001 -n istio-system
+  ~~~~
+
+- Создаем namespace
+   ~~~~
+   kubectl create namespace istio-backend
+   ~~~~
+
+- Переходим в папку проекта manifests: **cd "АДРЕС_ДО_ПРОЕКТА\otus-homework-istio\manifests"**. 
+  Предварительно с помощью Dockerfile из папки **otus-homework-istio\app\src** был сделан образ echoservice и залит на DockerHub.
+- Применяем манифесты
+
+  ~~~~
+  kubectl apply -f .  
+  ~~~~
+
+ - Нагружаем приложение http://localhost/ трафиком
+
+ - Переходим в kiali и видим граф 
+
+  ![Пример карты сервисов с балансировкой трафика между версиями](kiali-grath.jpg)

app/src/Dockerfile

@@ -0,0 +1,9 @@
+FROM python:3.7-slim
+
+EXPOSE 8080
+COPY requirements.txt /requirements.txt
+RUN pip install --no-cache-dir -r requirements.txt
+
+COPY app.py /app.py
+
+CMD ["python", "/app.py"]

app/src/app.py

@@ -0,0 +1,67 @@
+import platform
+
+from aiohttp import web, client, ClientResponseError
+
+routes = web.RouteTableDef()
+memoized_times = None
+
+
+@routes.get('/')
+async def hello(request: web.Request):
+    url = request.query.get('url', '')
+
+    headers = '\n'.join(f'{k}: {v}' for k, v in request.headers.items())
+
+    text = f'Request served by {platform.node()}\n\n'
+    text += f'{request.version} {request.method} {request.url}\n\n'
+    text += f'Request headers:\n\n{headers}\n\n'
+
+    if url:
+        s: client.ClientSession
+        r: client.ClientResponse
+
+        async with client.ClientSession(raise_for_status=True) as s:
+            data = None
+            if request.can_read_body:
+                data = await request.text()
+
+            ext_req_headers = {}
+            token = request.headers.get('X-AUTH-TOKEN')
+            if token:
+                ext_req_headers['X-AUTH-TOKEN'] = token
+
+            try:
+                async with s.request(request.method, url, headers=ext_req_headers, data=data) as r:
+                    body = await r.text()
+                    headers = '\n'.join(f'{k}: {v}' for k, v in r.headers.items())
+                    text += f'Remote status: {r.status}\n\nRemote headers:\n\n{headers}\n\nRemote body:\n\n{body}'
+            except ClientResponseError as e:
+                headers = '\n'.join(f'{k}: {v}' for k, v in e.headers.items())
+                text += f'Remote error with status: {e.status}\n\nRemote headers: {headers}'
+            except Exception as e:
+                text += f'Remote error: {str(e)}'
+
+    return web.Response(content_type='text/plain', text=text)
+
+
+@routes.get('/error')
+async def timeout(request: web.Request):
+    global memoized_times
+    times = int(request.query.get('times', '') or 0)
+
+    if memoized_times is None:
+        memoized_times = times + 1
+
+    memoized_times -= 1
+    status = 500
+
+    if memoized_times <= 0:
+        memoized_times = None
+        status = 200
+
+    return web.Response(content_type='text/plain', status=status)
+
+if __name__ == '__main__':
+    app = web.Application()
+    app.add_routes(routes)
+    web.run_app(app, port=8080)

app/src/requirements.txt

@@ -0,0 +1 @@
+aiohttp

manifests/deployment.yaml

@@ -0,0 +1,56 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: echoserver-v1
+  namespace: istio-backend
+  labels:
+    version: v1
+spec:
+  replicas: 1
+  strategy:
+    type: Recreate
+  selector:
+    matchLabels:
+      app: echoserver
+      version: "v1"
+  template:
+    metadata:
+      labels:
+        app: echoserver
+        version: "v1"
+    spec:
+      containers:
+        - name: echoserver
+          image: christinagorina/homework-9:1.0.0
+          imagePullPolicy: IfNotPresent
+          ports:
+            - containerPort: 8080
+
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: echoserver-v2
+  namespace: istio-backend
+  labels:
+    version: v2
+spec:
+  replicas: 1
+  strategy:
+    type: Recreate
+  selector:
+    matchLabels:
+      app: echoserver
+      version: "v2"
+  template:
+    metadata:
+      labels:
+        app: echoserver
+        version: "v2"
+    spec:
+      containers:
+        - name: echoserver
+          image: christinagorina/homework-9:1.0.0
+          imagePullPolicy: IfNotPresent
+          ports:
+            - containerPort: 8080