Kubernetes – Serverless computing своими руками
О технологиях

Kubernetes – Serverless computing своими руками

3833
11 минут

Как правило, вы пишете код в своем окружении разработчика, а затем создаете отдельное окружение для развертывания вашего кода и тестирования его работы. Даже для работы с небольшим количеством кода вам нужно пройти через процессы создания виртуальной машины или контейнера в облаке, деплоймента кода и дальнейшей его поддержки.

Идея безсерверных (serverless) вычислений заключается в том, что она позволяет вам, как разработчику, сосредоточиться только на написании кода. При использовании подхода безсерверных вычислений вы просто загружаете код куда-нибудь, а дальше он сам запускается всякий раз, когда вы или сторонний сервис его вызываете. Проще говоря, безсерверные вычисления освобождают вас от сложностей создания контейнеров Docker или настройки и поддержки кластеров Kubernetes.


В этом руководстве будет показано, как начать работу с бессерверными вычислениями с использованием платформы Kubeless, работающей поверх кластера Kubernetes в нашем уже развернутом кластере.


Введение

Для начала экспериментов с безсерверными вычислениями вам понадобятся:


Если работающий кластер Kubernetes у вас уже есть, то далее мы с вами сделаем следующее:

  • Запустим Dashboard в Kubernetes кластере
  • Установим Kubeless
  • Напишем облачную функцию
  • Зарегистрируем нашу функцию в Kubeless
  • Вызовем написанную нами функцию

Запуск Kubernetes Dashboard

Если у вас уже есть запущенный кластер Kubernetes, то скорее всего Dashboard у вас уже установлена. Проверить это можно командой:


$ kubectl get pods --all-namespaces | grep dashboard

Если Dashboard отсутствует, выполните следующую команду:


$ kubectl create -f https://git.io/kube-dashboard

Доступ к Dashboard по-умолчанию осуществляется через проксирование к нему запросов командой


$ kubectl proxy Starting to serve on 127.0.0.1:8001

Сам Dashboard при этом становится доступен по адресу http://localhost:8001/ui.

kubernetes_dashboard.png

Как только доступ к Kubernetes Dashboard получен, можно переходить к установке Kubeless.


Установка Kubeless

Kubeless — это приложение, предназначенное для развертывания поверх кластера Kubernetes. Оно принимает команды для регистрации, удаления и отображения списка функций, которые вы хотите запустить.


Используйте следующие команды для установки Kubeless:

$ curl -L https://github.com/skippbox/kubeless/releases/download/0.0.7/kubeless_linux-amd64.zip > kubeless.zip

$ unzip kubeless.zip

$ cd kubeless_linux-amd64

$ ./kubeless install

We are going to install the controller in the kubeless namespace. Are you OK with this: [Y/N]

Y

INFO[0002] Initializing Kubeless controller... pkg=controller

INFO[0002] Installing Kubeless controller into Kubernetes deployment... pkg=controller

INFO[0005] Kubeless controller installation finished! pkg=controller

INFO[0005] Installing Message Broker into Kubernetes deployment... pkg=controller

INFO[0007] Message Broker installation finished! pkg=controller


Далее можно либо скопировать kubeless в /usr/local/bin, либо прописать его расположение в $PATH. Я выберу первый вариант:

$ sudo cp kubeless /usr/local/bin


Протестируйте работу Kubeless, выполнив команду:

$ kubeless function ls

NAME HANDLER RUNTIME TYPE TOPIC NAMESPACE


Если зайти в Kubernetes Dashboard, можно увидеть пространство имен kubeless, которое дополнительно покажет, что Kubeless был успешно установлен.


Написание функции

Теперь, после того, как вас появился запущенный Kubeless, вы можете забыть о контейнерах, виртуальных машинах, Kubernetes и т.д. Все, что вам теперь нужно, это просто писать код.


Вот не сложный пример:

import urllib2

import json

def get_titles(request):

url = «https://jsonplaceholder.typicode.com/posts»

response = urllib2.urlopen(url)

posts = json.loads(response.read())

titles = []

for post in posts:

titles.append(post["title"])

return json.dumps(titles)


ПРИМЕЧАНИЕ: эта функция для простоты понимания сознательно написана без какой-либо обработки ошибок или проверок ввода. Не используйте эту функцию в ваших реальных приложениях.


Это очень простая функция, ее цель — просто вернуть список всех заголовков из ответа сервера. Чтобы добавить похожую функцию в существующее приложение, вы, как правило, интегрируете ее с существующей кодовой базой, создаете новые виртуальные машины или контейнеры и выполняете ее canary деплоймент. Однако, при использовании безсерверных вычислений вы можете просто зарегистрировать эту функцию, затем использовать ее в случае необходимости.


Сохраните эту функцию в файле, например, /tmp/test-function.py и переходите к следующему разделу.


Регистрация функции в Kubeless

Наш следующий шаг — зарегистрировать функцию с помощью Kubeless. Регистрация функции с помощью Kubeless включает в себя передачу Kubeless следующей информации:


  • Имя, которое вы будете использовать для доступа к функции
  • Протокол, к которому вы будете обращаться к функции (здесь, HTTP)
  • Окружение, в котором будет исполняться запущенный код (здесь, Python)
  • Имя файла, содержащего код функции
  • Имя функции внутри файла

Вся эта информация легко передается в Kubeless при помощи команды kubeless function create:


$ kubeless function create get_titles --trigger-http --runtime python27 --handler test-function.get_titles --from-file /tmp/test-function.py

Давайте разберем этот пример:


Команда kubeless create get_titles сообщает Kubeless зарегистрировать новую функцию с именем get_titles. Эта функция будет доступна по сети по протоколу HTTP. Обратите внимание, что имя не обязательно должно быть точно таким же, как имя функции в фале.


--trigger-http сообщает Kubeless, что функция будет вызываться через HTTP. Также можно запускать функцию другими способами, но это не тема данной статьи.


--runtime python27 сообщает Kubeless, что необходимо использовать Python 2.7 для исполения кода.


--handler test-function.get_titles сообщает Kubeless имя функции для вызова внутри Python модуля. Вы наверняка заметили в приведенном выше коде Python, что функция называется get_titles().


--from-file /tmp/test-function.py сообщает Kubeless, что необходимо загрузить и использовать файл /tmp/test-function.py в качестве исходника для этой функции.


Как только команда завершит выполнение, проверьте, что функция зарегистрирована в Kubeless, используя команду kubeless function ls:


$ kubeless function ls

Чтобы удалить эту функцию, выполните команду:


$ kubeless function create get_titles --trigger-http --runtime python27 --handler test-function.get_titles --from-file /tmp/test-function.py

Давайте разберем этот пример:


Команда kubeless create get_titles сообщает Kubeless зарегистрировать новую функцию с именем get_titles. Эта функция будет доступна по сети по протоколу HTTP. Обратите внимание, что имя не обязательно должно быть точно таким же, как имя функции в фале.


--trigger-http сообщает Kubeless, что функция будет вызываться через HTTP. Также можно запускать функцию другими способами, но это не тема данной статьи.


--runtime python27 сообщает Kubeless, что необходимо использовать Python 2.7 для исполения кода.


--handler test-function.get_titles сообщает Kubeless имя функции для вызова внутри Python модуля. Вы наверняка заметили в приведенном выше коде Python, что функция называется get_titles().


--from-file /tmp/test-function.py сообщает Kubeless, что необходимо загрузить и использовать файл /tmp/test-function.py в качестве исходника для этой функции.

Как только команда завершит выполнение, проверьте, что функция зарегистрирована в Kubeless, используя команду kubeless function ls:

$ kubeless function ls


Чтобы удалить эту функцию, выполните команду: $ kubeless function delete get_titles

Вызов функции

Давайте посмотрим на код нашей функции. Сразу видно, что функция ожидает, что она будет вызвана методом POST. Таким образом, для для ее вызова необходимо всего лишь отправить этот запрос:


$ curl localhost:8080/api/v1/proxy/namespaces/default/services/get_titles/ --header "Content-Type:application/json"

В ответ вы получите список тем постов демо json-сервиса.

19 октября 2023
Контейнеры: технологии и процессы глазами разработчика

В выпуске#9 видеоподкаста «Откровенно об ИТ-инфраструктуре» поговорили о роли контейнеров в разработке. Приглашенные эксперты обсудили специфику использования Kubernetes и сокращение time-to-market в контексте контейнеризации.

В гостях Михаил Гудов, Orion soft, и Василий Колосов, Smartex.
1 минута
779
19 июня 2023
Семь трендов на рынке облачных услуг в 2023 году
До 2022 года на рынке облаков в России главенствовали мировые тренды, но сейчас наша страна пошла своим путем. О том, для чего сейчас компании используют облачные технологии и как меняется рынок, рассказал директор по развитию КРОК Облачные сервисы Сергей Зинкевич.
1 минута
2181
16 июня 2023
Рулевой в океане контейнеров
Выпуск#3 видеоподкаста «Откровенно об ИТ-инфраструктуре» посвящен Kubernetes и профессиональным платформам оркестрации контейнеров. Обсудили, как сегодня складывается ситуация на российском рынке контейнерных платформ, что востребовано и почему, особенности и перспективы работы с Kubernetes.

В гостях Александр Баталов, Генеральный директор Флант
1 минута
1504
29 марта 2023
Сетевые балансировщики нагрузки и другие обновления Облака КРОК

Мы рады вам представить новый сервис Облака КРОК для распределения трафика между экземплярами – Балансировщики нагрузки. Кроме того, мы автоматизировали обновление сертификатов Kubernetes и добавили возможность удаления рабочих узлов из кластера Kubernetes.

2 минуты
915
15 ноября 2022
OpenShift остался без поддержки – как решить проблему российским клиентам
Интерес к семейству ПО для контейнеризации OpenShift был довольно высоким в корпоративном сегменте в прежние годы. По данным мониторинговой службы Datadog, только за прошлый год во всем мире количество пользователей платформ от RedHat увеличилось на 28%. Весной IBM объявил об уходе из России и прекращении поддержки всех программных продуктов для текущих клиентов. Разберемся, насколько критичной оказалась данная ситуация для заказчиков, и какие варианты действий существуют, чтобы минимизировать возможные риски отключения от сервиса.
1 минута
1028
scrollup