Образовательный проект «SnakeProject» Михаила Козлова

⇒ FreeBSD and Nix ⇐

CISCO

Voice(Asterisk\Cisco)

Microsoft

Powershell

Python

SQL\T-SQL

1С

Общая

WEB Разработка

ORACLE SQL \ JAVA

Мото

Стрельба, пневматика, оружие

Саморазвитие и психология

Go веб сервер + ansible

Go веб сервер + ansible

Продолжаем серию заметок

Простенький go web app аки сервис ченрез proxy nginx
Сама app будет делать пару простых запросов методом get в бд postgres

ОС системы - Ubuntu 22.04

ansible.cfg [defaults] host_key_checking=false inventory=./hosts.yml hosts.yml all: hosts: foobar: ansible_ssh_host: 1.1.1.1 ansible_ssh_private_key_file: /root/.ssh/id_rsa ansible_ssh_public_key_file: /root/.ssh/id_rsa.pub a01.yaml - hosts: - all become: true roles: - {role: 'postgres', tags: 'postgres'} - {role: 'go', tags: 'go'} - {role: 'nginx', tags: 'nginx'} roles\go\files\go_app.service [Unit] Description=openroad flow backend server daemon [Service] Type=simple ExecStart=/tmp/main Restart=on-failure RestartSec=10s WorkingDirectory=/tmp [Install] WantedBy=multi-user.target roles\go\files\main.go /* package main import ( "fmt" "log" "net/http" ) func main() { // API routes http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) { fmt.Fprintf(w, "Hello world!") }) http.HandleFunc("/hi", func(w http.ResponseWriter, r *http.Request) { fmt.Fprintf(w, "Hi world!") }) port := ":80" fmt.Println("Server is running on port" + port) // Start server on port specified above log.Fatal(http.ListenAndServe(port, nil)) } */ package main import ( "database/sql" "encoding/json" // "context" "net/http" "fmt" "log" _ "github.com/lib/pq" ) const ( host = "127.0.0.1" port = 5432 user = "app_user_name" password = "Your_Super_Pass" dbname = "app_db_name" ) var id int var db *sql.DB type Product struct { Id int Title string Price int } type Products struct { Products []Product } func main(){ var err error psqlInfo := fmt.Sprintf("host=%s port=%d user=%s password=%s dbname=%s sslmode=disable", host, port, user, password, dbname) db, err = sql.Open("postgres", psqlInfo) if err != nil { panic(err) } defer db.Close() fmt.Println("Successfully connected!") http.HandleFunc("/products/list", Request_products_list) http.HandleFunc("/products/", Request_product_information) log.Fatal(http.ListenAndServe(":321", nil)) } func Request_product_information(w http.ResponseWriter, r *http.Request){ if r.Method != "GET" { http.Error(w, "BAD METHOD", http.StatusForbidden) } else { id := r.URL.Query().Get("id") //fmt.Printf("GET id = %v\n", id) var title string var price int row := db.QueryRow("SELECT title, price FROM products WHERE id=$1", id) switch err := row.Scan(&title, &price); err { case sql.ErrNoRows: fmt.Println("No rows were returned!") case nil: // fmt.Printf("Product with title=%v and price=%v\n", title, price) fmt.Fprintf(w, "Product with title=%v and price=%v\n", title, price) default: panic(err) } } } func Request_products_list(w http.ResponseWriter, r *http.Request){ if r.Method != "GET" { http.Error(w, "BAD METHOD", http.StatusForbidden) } else { w_array := Products{} rows, err := db.Query("SELECT id, title, price FROM products") if err != nil { panic(err) } for rows.Next() { w_product := Product{} err := rows.Scan(&w_product.Id,&w_product.Title,&w_product.Price) if err != nil { panic(err) } w_array.Products = append(w_array.Products, w_product) // fmt.Fprintf(w, "Product with id=%v, title=%v, price=%v\n", w_product.Id,w_product.Title,w_product.Price) } json.NewEncoder(w).Encode(w_array) } } development\roles\go\handlers\main.yml --- - name: Start go_app systemd: name: go_app state: started enabled: yes development\roles\go\tasks\main.yml --- - name: Install golang apt: name: golang state: present update_cache: true - name: Depends to script shell: cd /tmp && go mod init module-name && go env -w GO111MODULE=auto && go get -u github.com/lib/pq - name: Copy golang script copy: src: "{{ role_path }}/files/main.go" dest: /tmp/main.go - name: Build golang script shell: cd /tmp && go build /tmp/main.go - name: Copy golang service copy: src: "{{ role_path }}/files/go_app.service" dest: "/etc/systemd/system/go_app.service" - name: Apply daemon-reload command: systemctl daemon-reload notify: - Start go_app roles\nginx\files\hw.conf server { listen 80; server_name your_domain_name.ru; # root /var/www/html; location / { # try_files $uri $uri/ /index.html; proxy_pass http://127.0.0.1:321; } } roles\nginx\handlers\main.yml --- - name: nginx start systemd: name: nginx enabled: yes state: started roles\nginx\tasks\main.yml --- - name: Install packages apt: pkg: - nginx state: latest update_cache: true - name: Create www dir file: path: "/var/www/html" state: directory - name: Nginx app conf copy: src: hw.conf dest: /etc/nginx/sites-enabled/hw.conf notify: - nginx start - name: Apply daemon-reload command: systemctl daemon-reload - name: restart nginx service: name: nginx state: restarted become: yes roles\postgres\vars\main.yml --- db_user: app_user_name db_password: Your_Super_Pass db_name: app_db_name roles\postgres\handlers\main.yml --- - name: restart postgres service: name=postgresql state=restarted roles\postgres\tasks\main.yml - name: Install packages ansible.builtin.apt: name: - postgresql-14 - postgresql-contrib - libpq-dev - python3-psycopg2 - python3-pip state: present - name: "Install Python packages" pip: name: ['psycopg2-binary'] - name: "Start and enable services" service: "name={{ item }} state=started enabled=yes" with_items: - postgresql - name: "Create app database" postgresql_db: state: present name: "{{ db_name }}" become: yes become_user: postgres - name: "Create db user" postgresql_user: state: present name: "{{ db_user }}" password: "{{ db_password }}" become: yes become_user: postgres - name: "Grant db user access to app db" postgresql_privs: type: database database: "{{ db_name }}" roles: "{{ db_user }}" grant_option: no privs: all become: yes become_user: postgres - name: "Allow md5 connection for the db user" postgresql_pg_hba: dest: "~/14/main/pg_hba.conf" contype: host databases: all method: md5 users: "{{ db_user }}" create: true become: yes become_user: postgres notify: restart postgres - name: Create table products community.postgresql.postgresql_table: db: "{{ db_name }}" login_user: "{{ db_user }}" login_password: "{{ db_password }}" login_host: "127.0.0.1" name: products columns: - id bigserial primary key - price bigint - title text - name: Insert grape to table community.postgresql.postgresql_query: db: "{{ db_name }}" login_user: "{{ db_user }}" login_password: "{{ db_password }}" login_host: "127.0.0.1" query: INSERT INTO products (id, title, price) VALUES (1, 'grape', 15) - name: Insert cheeze to table community.postgresql.postgresql_query: db: "{{ db_name }}" login_user: "{{ db_user }}" login_password: "{{ db_password }}" login_host: "127.0.0.1" query: INSERT INTO products (id, title, price) VALUES (2, 'cheeze', 25)

Проверяем:
http://your_domain_name.ru:321/products/list
http://your_domain_name.ru/products/list
http://your_domain_name.ru:321/products/?id=2
http://your_domain_name.ru/products/?id=2

Комментарии пользователей