Kerangka lain ...

Kemarin saya merilis framework Python pertama saya. Tidak, tidak yang lain. Ini ada di dunia - satu sama lain. Dan bagi saya sejauh ini yang pertama. Dan saya akui bahwa dia adalah yang pertama dari jenisnya. Ini adalah kerangka kerja untuk membangun server khusus. Dan mereka akan dibuat melalui konfigurasi. Wah, yuk buat sekarang ...

---

Awalnya ada konfigurasi

Jadi, config. Karena kami telah menginstal kerangka pada saat ini. Dan jika tidak, maka itu mudah dan sederhana untuk dilakukan dengan perintah:

pip3 install idewavecore==0.0.1
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

Ini dengan asumsi Anda memiliki Python 3.6+, internet, dan komputer .

Konfigurasi itu sendiri terlihat seperti ini:

# settings.yml
settings:
  servers: !inject config_dir/servers.yml
  db_connections:
    sqlite:
      host: ~
      username: ~
      password: ~
      # default mysql 3306, postgresql 5432, sqlite don't need port
      port: ~
      # currently allowed: mysql, postgresql, sqlite
      dialect: sqlite
      # supported drivers:
      # mysql: mysqlconnector, pymysql, pyodbc
      # postgresql: psycopg2, pg8000, pygresql
      driver: ~
      # to use with sqlite this should be absolute db path
      # can be empty to keep db in memory (sqlite only)
      db_name: ~
      charset: ~
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

!inject



- yaml . , yaml- -.

# servers.yml
sample_server:
  connection:
    host: 1.2.3.4
    port: 1234
    # possible values: tcp, websocket
    connection_type: tcp
  # optional
  proxy:
    host: ~
    port: ~
    # possible values: tcp, websocket
    connection_type: tcp
  options:
    server_name: Sample Server
    is_debug: false
  middlewares: !pipe
    - !fn native.test.mock_middleware
    - !fn native.test.mock_middleware
    - !infinite_loop
        - !fn native.test.mock_middleware
        - !fn native.test.mock_middleware
        - !fn native.test.mock_middleware
        - !router
            ROUTE_1: !fn native.test.mock_middleware
            ROUTE_2: !fn native.test.mock_middleware
            ROUTE_3:
              - !fn native.test.mock_middleware
              - !fn native.test.mock_middleware
              - !fn native.test.mock_middleware
  # optional
  db_connection: sqlite
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

.

!pipe



- , . , middlewares ( - ), . - .

!infinite_loop



- , . (, websocket).

!router



- , . , , (route).

, , !fn



- , ( - middleware) . , - - middlewares - . , , :

!fn <__>.<_>

. (middlewares) - . (! !), native



, :

!fn native.test.mock_middleware

, .

Middle where

- , . , - . .

, - , ( - ). :

from idewavecore.session import Storage, ItemFlag


async def sample_middleware(**kwargs):
    global_storage: Storage = kwargs.pop('global_storage')
    server_storage: Storage = kwargs.pop('server_storage')
    session_storage: Storage = kwargs.pop('session_storage')

    session_storage.set_items([
        {
            'key1': {
                'value': 'some_tmp_value'
            }
        },
        {
            'key2': {
                'value': 'some_persistent_value',
                'flags': ItemFlag.PERSISTENT
            }
        },
        {
            'key3': {
                'value': 'some_persistent_constant_value',
                'flags': ItemFlag.PERSISTENT | ItemFlag.FROZEN
            }
        },
        {
            'key4': {
                'value': 'some_constant_value',
                'flags': ItemFlag.FROZEN
            }
        }
    ])

    value_of_key3 = session_storage.get_value('key3')
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

(storage). : (global storage), (server storage) (session storage).

, .

.

.

.

( , . . , -. - , .)

...

, - Assembler. , . :

# run.py
import asyncio

from idewavecore import Assembler
from idewavecore.session import Storage

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    global_storage = Storage()

    assembler = Assembler(
        global_storage=global_storage,
        #    
        config_path='settings.yml'
    )

    servers = assembler.assemble()
    for server in servers:
        server.start()

    loop.run_until_complete(
        asyncio.gather(*[server.get() for server in servers])
    )

    try:
        loop.run_forever()
    except KeyboardInterrupt:
        pass
    finally:
        loop.close()
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
    

- ( , ) , . - , curl, mmo rpg ...

Dan sekarang saya ingin mengucapkan terima kasih kepada semua orang yang membaca posting saya sampai akhir. Saya akan berterima kasih atas komentar yang membangun. Bahkan jika kerangka saya bukan yang pertama dari jenisnya, saya ingin membuatnya sedekat mungkin dengan bilah ini.

Bergabunglah dengan kami .