قم بإنشاء TODO API لـ Golang باستخدام Kubernetes

قائمة المكونات الضرورية:

• عامل ميناء مثبت محليًا

• مجموعة Kubernetes

• جولانج

• IDE

إنشاء كتلة

إنشاء كتلة جديدة باستخدام k3d:

export KUBECONFIG="$(k3d get-kubeconfig --name='k3s-default')"

kubectl get node
NAME                     STATUS   ROLES    AGE   VERSION
k3d-k3s-default-server   Ready    master   48s   v1.17.0+k3s.1

تثبيت ممر

curl -sLS https://dl.get-arkade.dev | sudo sh

arkade install postgresql
===================================================================== = PostgreSQL has been installed.                                    =
=====================================================================

CREATE TABLE todo (
 id              INT GENERATED ALWAYS AS IDENTITY,
 description     text NOT NULL,
 created_date    timestamp NOT NULL,
 completed_date  timestamp NOT NULL
);

export POSTGRES_PASSWORD=$(kubectl get secret --namespace default postgresql -o jsonpath="{.data.postgresql-password}" | base64 --decode)
kubectl run postgresql-client --rm --tty -i --restart='Never' --namespace default --image docker.io/bitnami/postgresql:11.6.0-debian-9-r0 --env="PGPASSWORD=$POSTGRES_PASSWORD" --command -- psql --host postgresql -U postgres -d postgres -p 5432

postgres=# \dt
List of relations
Schema | Name | Type  |  Owner
--------+------+-------+----------
public | todo | table | postgres
(1 row)

تثبيت إطار التطبيق

• يوفر Prometheus المقاييس ، والتحجيم التلقائي ، والملاحظة لاختبار صحة النظام الخاص بك ، ويسمح لها بالاستجابة للطفرات في الطلب وخفض التكاليف من خلال توفير المقاييس لاتخاذ قرارات حول التوسع إلى الصفر.
• لينكس ، على الرغم من أنه ليس الخيار الوحيد لتشغيل أحمال العمل في Kubernetes ، إلا أنه قياسي وأسهل في الاستخدام.
• في البداية ، قدمت OpenFaaS وظائف محمولة للمطورين ، ولكنها تعمل بشكل رائع عند نشر واجهات برمجة التطبيقات والخدمات الدقيقة. تعدد استخداماتها يعني أن أي حاويات Docker مع خادم HTTP يمكن نشرها وإدارتها.
• NATS هو مشروع CNCF شائع يستخدم في المراسلة والنشر / الفرعية. في مكدس PLONK ، فإنه يوفر القدرة على تنفيذ الطلبات بشكل غير متزامن وقائمة انتظار.
• Kubernetes هو سبب وجودنا هنا. إنه يوفر بنية تحتية قابلة للتطوير وذاتية التصعيد. وإذا لم تعد بحاجة إلى جزء من كل هذه العظمة ، فإن واجهة برمجة التطبيقات الخاصة به مبسطة باستخدام OpenFaaS.

arkade install openfaas

• تثبيت faas-cli.
• احصل على كلمة المرور الخاصة بك.
• إعادة توجيه واجهة مستخدم بوابة OpenFaaS (عبر المنفذ 8080)
• وتسجيل الدخول إلى النظام من خلال CLI.

انشر واجهة برمجة تطبيقات First Go

faas-cli template store list | grep go
go                       openfaas           Classic Golang template
golang-http              openfaas-incubator Golang HTTP template
golang-middleware        openfaas-incubator Golang Middleware template

faas-cli template store pull golang-middleware

export PREFIX=alexellis2
export LANG=golang-middleware
export API_NAME=todo
faas-cli new --lang $LANG --prefix $PREFIX $API_NAME

• ./todo.yml - يوفر طريقة لتكوين ونشر وتثبيت القالب والاسم
• ./todo/handler.go - هنا تكتب الرمز وتضيف أي ملفات أو حزم أخرى تطلبها

package function
import (
   "net/http"
   "encoding/json"
)
type Todo struct {
   Description string `json:"description"`
}
func Handle(w http.ResponseWriter, r *http.Request) {
   todos := []Todo{}
   todos = append(todos, Todo{Description: "Run faas-cli up"})
   res, _ := json.Marshal(todos)
   w.WriteHeader(http.StatusOK)
   w.Header().Set("Content-Type", "application/json")
   w.Write([]byte(res))
}

gofmt -w -s ./todo/handler.go

Invoke your endpoint when ready:
curl http://127.0.0.1:8080/function/todo
{
"description": "Run faas-cli up"
}

السماح للمستخدمين بإنشاء سجلات TODO جديدة

import (
   "database/sql"
   _ "github.com/lib/pq"
...

var db *sql.DB

cd todo/
ls
handler.go
export GO111MODULE=on
go mod init

go get
go mod tidy
cat go.mod
module github.com/alexellis/todo1/todo
go 1.13
require github.com/lib/pq v1.3.0

cat go.mod > GO_REPLACE.txt

faas-cli build -f todo.yml --build-arg GO111MODULE=on

Step 16/29 : RUN go test ./... -cover
---> Running in 9a4017438500
go: downloading github.com/lib/pq v1.3.0
go: extracting github.com/lib/pq v1.3.0
go: finding github.com/lib/pq v1.3.0
?       github.com/alexellis/todo1/todo [no test files]
Removing intermediate container 9a4017438500

تكوين أسرار الوصول إلى Postgresql

// init       .   ,     ,   /   /

func init() {
       if _, err := os.Stat("/var/openfaas/secrets/password"); err == nil {
               password, _ := sdk.ReadSecret("password")
               user, _ := sdk.ReadSecret("username")
               host, _ := sdk.ReadSecret("host")
               dbName := os.Getenv("postgres_db")
               port := os.Getenv("postgres_port")
               sslmode := os.Getenv("postgres_sslmode")
               connStr := "postgres://" + user + ":" + password + "@" + host + ":" + port + "/" + dbName + "?sslmode=" + sslmode
var err error
               db, err = sql.Open("postgres", connStr)
               if err != nil {
                       panic(err.Error())
               }
               err = db.Ping()
               if err != nil {
                       panic(err.Error())
               }
       }
}

export POSTGRES_PASSWORD=$(kubectl get secret --namespace default postgresql -o jsonpath="{.data.postgresql-password}" | base64 --decode)
export USERNAME="postgres"
export PASSWORD=$POSTGRES_PASSWORD
export HOST="postgresql.default"
faas-cli secret create username --from-literal $USERNAME
faas-cli secret create password --from-literal $PASSWORD
faas-cli secret create host --from-literal $HOST

faas-cli secret ls
NAME
username
password
host
# And via kubectl:
kubectl get secret -n openfaas-fn
NAME                  TYPE                                  DATA   AGE
username              Opaque                                1      13s
password              Opaque                                1      13s
host                  Opaque                                1      12s

secrets:
   - host
   - password
   - username
   environment:
     postgres_db: postgres
     postgres_sslmode: "disable"
     postgres_port: 5432

cd todo
go get
go mod tidy
cd ..
faas-cli build -f todo.yml --build-arg GO111MODULE=on
Successfully built d2c609f8f559
Successfully tagged alexellis2/todo:latest
Image: alexellis2/todo:latest built.
[0] < Building todo done in 22.50s.
[0] Worker done.
Total build time: 22.50s

faas-cli logs todo
2020-03-26T14:10:03Z Forking - ./handler []
2020-03-26T14:10:03Z 2020/03/26 14:10:03 Started logging stderr from function.
2020-03-26T14:10:03Z 2020/03/26 14:10:03 Started logging stdout from function.
2020-03-26T14:10:03Z 2020/03/26 14:10:03 OperationalMode: http
2020-03-26T14:10:03Z 2020/03/26 14:10:03 Timeouts: read: 10s, write: 10s hard: 10s.
2020-03-26T14:10:03Z 2020/03/26 14:10:03 Listening on port: 8080
2020-03-26T14:10:03Z 2020/03/26 14:10:03 Metrics listening on port: 8081
2020-03-26T14:10:03Z 2020/03/26 14:10:03 Writing lock-file to: /tmp/.lock

echo | faas-cli invoke todo -f todo.yml
2020-03-26T14:11:02Z 2020/03/26 14:11:02 POST / - 200 OK - ContentLength: 35

err = db.Ping()
if err != nil {
   panic(err.Error())
}

كتابة كود الإدراج

func insert(description string) error {
       res, err := db.Query(`insert into todo (id, description, created_date) values (DEFAULT, $1, now());`,
               description)
       if err != nil {
               return err
       }
       defer res.Close()
       return nil
}

func Handle(w http.ResponseWriter, r *http.Request) {
       if r.Method == http.MethodPost && r.URL.Path == "/create" {
               defer r.Body.Close()
               body, _ := ioutil.ReadAll(r.Body)
               if err := insert(string(body)); err != nil {
                       http.Error(w, fmt.Sprintf("unable to insert todo: %s", err.Error()), http.StatusInternalServerError)
               }
       }
}

echo | faas-cli invoke todo -f todo.yml
curl http://127.0.0.1:8080/function/todo/create --data "faas-cli build"
curl http://127.0.0.1:8080/function/todo/create --data "faas-cli push"
curl http://127.0.0.1:8080/function/todo/create --data "faas-cli deploy"

faas-cli logs todo
2020-03-26T14:35:29Z 2020/03/26 14:35:29 POST /create - 200 OK - ContentLength: 0

export POSTGRES_PASSWORD=$(kubectl get secret --namespace default postgresql -o jsonpath="{.data.postgresql-password}" | base64 --decode)
kubectl run postgresql-client --rm --tty -i --restart='Never' --namespace default --image docker.io/bitnami/postgresql:11.6.0-debian-9-r0 --env="PGPASSWORD=$POSTGRES_PASSWORD" --command -- psql --host postgresql -U postgres -d postgres -p 5432
postgres=# select * from todo;
id |   description   |        created_date        | completed_date
----+-----------------+----------------------------+----------------
1 | faas-cli build  | 2020-03-26 14:36:03.367789 |
2 | faas-cli push   | 2020-03-26 14:36:03.389656 |
3 | faas-cli deploy | 2020-03-26 14:36:03.797881 |

طلب تسجيل

func selectTodos() ([]Todo, error) {
   var error err
   var todos []Todo
   return todos, err
}

} else if r.Method == http.MethodGet && r.URL.Path == "/list" {
   todos, err := selectTodos()
   if err != nil {
       http.Error(w, fmt.Sprintf("unable to get todos: %s", err.Error()), http.StatusInternalServerError)
   }
   out, _ := json.Marshal(todos)
   w.Header().Set("Content-Type", "application/json")
   w.Write(out)
}

type Todo struct {
   ID int `json:"id"`
   Description   string `json:"description"`
   CreatedDate   *time.Time `json:"created_date"`
   CompletedDate *time.Time `json:"completed_date"`
}

func selectTodos() ([]Todo, error) {
       rows, getErr := db.Query(`select id, description, created_date, completed_date from todo;`)
   if getErr != nil {
       return []Todo{}, errors.Wrap(getErr, "unable to get from todo table")
   }
   todos := []Todo{}
   defer rows.Close()
   for rows.Next() {
       result := Todo{}
       scanErr := rows.Scan(&result.ID, &result.Description, &result.CreatedDate, &result.CompletedDate)
       if scanErr != nil {
           log.Println("scan err:", scanErr)
       }
       todos = append(todos, result)
   }
   return todos, nil
}

faas-cli up -f todo.yml --build-arg GO111MODULE=on
curl http://127.0.0.1:8080/function/todo/list

[
 {
   "id": 2,
   "description": "faas-cli build",
   "created_date": "2020-03-26T14:36:03.367789Z",
   "completed_date": null
 },
 {
   "id": 3,
   "description": "faas-cli push",
   "created_date": "2020-03-26T14:36:03.389656Z",
   "completed_date": null
 },
 {
   "id": 4,
   "description": "faas-cli deploy",
   "created_date": "2020-03-26T14:36:03.797881Z",
   "completed_date": null
 }
]

CompletedDate *time.Time `json:"completed_date,omitempty"`

لتلخيص العمل المنجز

• تثبيت Go و Docker و kubectl و VSCode (IDE)
• نشر Kubernetes على جهاز الكمبيوتر المحلي
• تم تثبيت Postgresql باستخدام arkade و helm3
• تم تثبيت OpenFaaS ومكدس PLONK لمطوري تطبيقات Kubernetes
• إنشاء واجهة برمجة تطبيقات REST الثابتة الأولية باستخدام Go golang-middlewareونموذج OpenFaaS
• تمت إضافة وظيفة "insert" إلى واجهة برمجة تطبيقات TODO
• تمت إضافة وظائف مختارة إلى TODO API

• إضافة المصادقة باستخدام رمز حامل ثابت
• قم بإنشاء صفحة ويب باستخدام قالب HTML أو React ثابت لتقديم قائمة TODO وإنشاء عناصر جديدة.
• إضافة دعم متعدد المستخدمين إلى API