2025-03-06 Meeting 6

Sadarbības iespējas uz AI

Sazināties vai ir intrese AI risinājumus ieviest uzņēmumam, kurš nodarbojas ar Lidmašīnu tehniskā apkope, krievu uzņēmums, Airline support baltic, Union aviotian

Quality Control prezentācija: https://share.yellowrobot.xyz/quick/2025-3-8-C1748CC8-11E5-4B7A-8393-97B40CE2C352.pdf

Code Review

Veikt labojumus

https://github.com/MontaAleksandra/DuckHunt_game

API uzdevums

Izveidot jaunu private git, nosharot ar evaldsurtans. API atslēgas, DB pieejas utt nelikt iekšā GIT.

Izmantojot FastAPI, SwaggerUI, Dataclasses, MVC, PostgreSQL implementēt API, kur var augšupielādēt nestrukturizētu tāmju Excel failu un saņemt kā rezultātu strukturizētu tāmi.

Obligāti sadalīt API divos workeros, viens ir FastAPI view, kurš saņem un atdod pieprasījumus ar vismaz 2 funkcijām /task_submit un /task_status

Un otru worker, kurš fonā while loopā ar nelielu time.sleep starp iterācijām apstrādā DB reģistrētos pieprasījumus.

Paralēli ir palaisti 2 python scripts, katrs savā linux screen (virtuālajā konsolē) Noderīgas linux komandas (itsevišķi saistībā ar screen) https://share.yellowrobot.xyz/quick/2025-3-6-63B8EE7D-B3BD-4F1F-AF3D-1EB9CECFDD79.html

Piemērs: https://api.asya.ai/docs

API Input jābūt API_KEY (uzģenerēts UUID, kas nav publiski zināms), Tāmes fails Excel formātā, paraugi https://share.yellowrobot.xyz/quick/2025-3-6-6B63F79C-FEFF-48B1-B228-B1F5AB883661.zip Nosūta serverim ar task_submit

API Output jabūt dataclass_json, lai veidojas šāds rezultāts (iegūst ar task_status)

xxxxxxxxxx
32
1
[
2
  {
3
    sheet_name: str,
4
    positions: [    
5
    {
6
      poistion: str,
7
      amount: float,
8
      price: float,
9
    },
10
    {
11
      poistion: str,
12
      amount: float,
13
      price: float,
14
    }
15
    ]
16
  },
17
  {
18
    sheet_name: str,
19
    positions: [    
20
    {
21
      poistion: str,
22
      amount: float,
23
      price: float,
24
    },
25
    {
26
      poistion: str,
27
      amount: float,
28
      price: float,
29
    }
30
    ]
31
  }
32
]

Servera piekļuve

Macos: Lai izmantotu SSH iesaku izmantot Termius vai SSH terminal https://iterm2.com/

Priekš SFTP izmantot FileZilla vai Transmit => The best alternative to FileZilla (https://panic.com/transmit/) - First use trial version

Windows: Piemērs kā izmantot WinSCP un Putty, lai tiktu klāt serverim https://www.youtube.com/watch?v=9iH3R6Zc_GM

xxxxxxxxxx
1
1
h: 62.122.20.14
2
u: devtestapi
3
Autentifikācija ar atslēgas failu

Serviss ir palaist šeit

https://devtestapi.asya.ai

Localhost saistība ar portu 8854

Salinkots caur nginx, bet to nevajag aiztikt

Python ir palaists ar piemēram:

x
1
micromamba activate devtestapi
2
cd /home/devtestapi/app
3
python3 ./app.py

tajā ar var uzinstalēt jaunus packages ar micromamba install numpy piemēram

PostgreSQL ieteicams pieslēgties ar PyCharm Database Plugin!

Video kā izmantot Linux screen: https://www.youtube.com/watch?v=_ZJiEX4rmN4

API (pašlaik dummy script) palaists uz

screen -rd api

Worker dummy script palaists uz

screen -rd worker

x
1
micromamba activate devtestapi
2
cd /home/devtestapi/app
3
python3 ./worker.py

Piemēra fails, bet jāpārtaisa korektā MVC struktūrā

xxxxxxxxxx
1
83
1
import psycopg2
2
import time
3
import random
4
import string
5

6
def generate_random_event():
7
    """Generate a random event string."""
8
    event_length = random.randint(10, 30)
9
    return ''.join(random.choice(string.ascii_letters + string.digits) for _ in range(event_length))
10

11
def connect_to_db():
12
    """Connect to the PostgreSQL database."""
13
    conn = psycopg2.connect(
14
        dbname="devtestapi",
15
        user="devtestapi",
16
        password="50zw7VAKnHhrKkIQkbQz",
17
        host="62.122.20.14",
18
        port="5432"
19
    )
20
    return conn
21

22
def insert_event(conn, event):
23
    """Insert an event into the test_table."""
24
    cursor = conn.cursor()
25
    insert_query = "INSERT INTO test_table (event_register) VALUES (%s) RETURNING test_table_id;"
26
    cursor.execute(insert_query, (event,))
27
    record_id = cursor.fetchone()[0]
28
    conn.commit()
29
    cursor.close()
30
    return record_id
31

32
def delete_old_records(conn):
33
    """Delete oldest records when there are more than 50 records."""
34
    cursor = conn.cursor()
35
    
36
    # Count records
37
    cursor.execute("SELECT COUNT(*) FROM test_table;")
38
    count = cursor.fetchone()[0]
39
    
40
    if count > 50:
41
        # Delete oldest records keeping only the newest 50
42
        cursor.execute("""
43
            DELETE FROM test_table 
44
            WHERE test_table_id IN (
45
                SELECT test_table_id 
46
                FROM test_table 
47
                ORDER BY test_table_id 
48
                LIMIT %s
49
            );
50
        """, (count - 50,))
51
        deleted_count = cursor.rowcount
52
        print(f"Deleted {deleted_count} old records")
53
    
54
    conn.commit()
55
    cursor.close()
56

57
def main():
58
    try:
59
        conn = connect_to_db()
60
        print("Connected to PostgreSQL database!")
61
        
62
        while True:
63
            # Generate and insert random event
64
            event = generate_random_event()
65
            record_id = insert_event(conn, event)
66
            print(f"Inserted event with ID {record_id}: {event}")
67
            
68
            # Check and delete old records
69
            delete_old_records(conn)
70
            
71
            # Wait for 60 seconds
72
            print("Waiting 60 seconds before next insertion...")
73
            time.sleep(60)
74
            
75
    except Exception as e:
76
        print(f"Error: {e}")
77
    finally:
78
        if conn:
79
            conn.close()
80
            print("Database connection closed.")
81

82
if __name__ == "__main__":
83
    main()

Jābūt requirments.txt vai environment.yaml ar visām izmantotajām libraries.

Nepieciešams visas izmaiņas veikt GIT, bet arī uzstādīt uz servera.