कुबेरनेट्स के साथ गोलंग के लिए एक TODO एपीआई बनाएं

आवश्यक घटकों की सूची:

• स्थानीय रूप से स्थापित डॉकर

• कुबेरनेट्स क्लस्टर

• Golang

• आईडीई

एक क्लस्टर बनाएँ

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)

एप्लिकेशन फ्रेमवर्क स्थापित करें

• प्रोमेथियस आपके सिस्टम के स्वास्थ्य का परीक्षण करने के लिए मेट्रिक्स, ऑटो-स्केलिंग और अवलोकन प्रदान करता है, यह शून्य में स्केलिंग के बारे में निर्णय लेने के लिए मैट्रिक्स प्रदान करके मांग में वृद्धि और कटौती की प्रतिक्रिया देता है।
• लिनक्स, हालांकि कुबेरनेट्स में वर्कलोड चलाने का एकमात्र विकल्प नहीं है, मानक और उपयोग करने में आसान है।
• प्रारंभ में, OpenFaaS ने डेवलपर्स को पोर्टेबल फ़ंक्शंस प्रदान किए, लेकिन एपीआई और माइक्रोसॉफ़्ट को तैनात करते समय यह बहुत अच्छा काम करता है। इसकी बहुमुखी प्रतिभा का अर्थ है कि HTTP सर्वर वाले किसी भी डॉकटर कंटेनर को तैनात और प्रबंधित किया जा सकता है।
• NATS संदेश और पब / उप के लिए उपयोग की जाने वाली एक लोकप्रिय सीएनसीएफ परियोजना है। PLONK स्टैक में, यह एसिंक्रोनस रूप से और कतार के लिए अनुरोधों को निष्पादित करने की क्षमता प्रदान करता है।
• कुबेरनेत हम यहां हैं। यह एक स्केलेबल, स्व-चिकित्सा और घोषणात्मक बुनियादी ढांचा प्रदान करता है। और अगर आपको अब इस भव्यता का हिस्सा नहीं चाहिए, तो OpenFaaS के साथ इसका API सरल है।

arkade install openfaas

• Faas-cli स्थापित करें।
• अपना पासवर्ड प्राप्त करें।
• OpenFaaS गेटवे UI (पोर्ट 8080 के माध्यम से) पुनर्निर्देशित करें
• और CLI के माध्यम से सिस्टम में लॉग इन करें।

अपने पहले जाओ एपीआई तैनात करें

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 Access के लिए गोपनीयता कॉन्फ़िगर करना

// 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"`

किए गए कार्यों का संक्षेप में वर्णन करना

• स्थापित गो, डॉकर, कुब्लेट और VSCode (IDE)
• हमारे स्थानीय कंप्यूटर पर कुबेरनेट की तैनाती की
• आर्कगेड और हेल्म 3 का उपयोग करके पोस्टग्रैस्कल स्थापित किया
• Kubernetes अनुप्रयोग डेवलपर्स के लिए OpenFaaS और PLONK स्टैक स्थापित किया गया
• Go और golang-middlewareOpenFaaS टेम्पलेट का उपयोग करके प्रारंभिक स्थैतिक REST API बनाया गया
• हमारे TODO एपीआई के लिए "सम्मिलित" कार्यक्षमता जोड़ा गया
• हमारे TODO एपीआई के लिए जोड़ा कार्यक्षमता का चयन करें

• एक स्थैतिक वाहक टोकन का उपयोग करके प्रमाणीकरण जोड़ना
• TODO सूची रेंडर करने और नए तत्व बनाने के लिए एक स्थिर HTML या रिएक्ट टेम्पलेट का उपयोग करके एक वेब पेज बनाएँ।
• एपीआई में बहु-उपयोगकर्ता समर्थन जोड़ना