ЖЗГ - Страница 49 из 293 - Жизнь замечательных грибов

Новый проект. DHCP сервер с выборкой из БД на Python

Задачей было написать аналог проекта DHCP2DB , но только на Python вместо C. В принципе […]

Читать далее »
Arduino Uno краткий обзор..

Ну на самом деле таких обзоров в «интернетиках» пруд пруди.. Ну чтож, внесу и я […]

Читать далее »
Получение данных из Active Directory посредством PHP

Сам за себя лучше всего расскажет мой кусок кода. Все сдобрено максимально большим количеством комментариев. […]

Читать далее »

Оформление службы в systemd из файла python

05.09.2022 Павел Грибов Python

Для того чтобы служба полноценно работала, в файле python необходимо предусмотреть:

Блокировку запуска копии скрипта
Создание pid файла с номером процесса

Теоретически это возможно возложить и на плечи systemd, но «классически» делать это самому.

Пример создания pid файла:

import os
    # выясним id процесса т создадим pid файл
    try:
        pid=os.getpid()
        with open(f"/var/run/ocpp_{sys.argv[1]}.pid", "w") as file:
            file.write(str(pid))
    except Exception as e:
        functions.logapi.error(f"Не удалось создать PID файл {e}");

import os

# выясним id процесса т создадим pid файл

try:

pid=os.getpid()

with open(f"/var/run/ocpp_{sys.argv[1]}.pid", "w") as file:

file.write(str(pid))

except Exception as e:

functions.logapi.error(f"Не удалось создать PID файл {e}");

Пример блокировки запуска копии:

from filelock import FileLock,Timeout    
    lock = FileLock(f"{sys.argv[1]}.lock",0)
    try:
        lock.acquire()
    except Timeout:
        functions.logapi.error(f"инстанс {sys.argv[1]} уже запущен на сервере");
        exit(-1);
    with lock:
        functions.logapi.debug(f"включена блокировка запусков других инстансов");

from filelock import FileLock,Timeout

lock = FileLock(f"{sys.argv[1]}.lock",0)

try:

lock.acquire()

except Timeout:

functions.logapi.error(f"инстанс {sys.argv[1]} уже запущен на сервере");

exit(-1);

with lock:

functions.logapi.debug(f"включена блокировка запусков других инстансов");

Пример файла настройки службы в этом случае (xx.service):

[Unit]
Description=ocpp1

[Service]
ExecStart=python3 /home/user/цувцув/цувцу.py ocpp1
PIDFile=/var/run/ocpp_ocpp1.pid

[Install]
WantedBy=multi-user.target

[Unit]

Description=ocpp1

[Service]

ExecStart=python3 /home/user/цувцув/цувцу.py ocpp1

PIDFile=/var/run/ocpp_ocpp1.pid

[Install]

WantedBy=multi-user.target

В Ubuntu его необходимо положить в /etc/systemd/system и перезапустить службу:

sudo systemctl daemon-reload

1	sudo systemctl daemon-reload

Оставить комментарий python, service, systemd

Python: минимальный каркас websocket сервера

25.08.2022 Павел Грибов Python

Из «коробки» в этом каркасе работа в потоках для обработки каждого сообщения. Собрано на основе пакета websockets.

Все клиенты хранятся в массиве clients. При отключении клиента — из массива он удаляется.

#!/usr/bin/env python3
#encoding: utf-8
import asyncio
import sys
import os
import websockets
from threading import Thread

# массив клиентов
clients=[]

# отправляем сообщение
def SendMessage(connect, message):
    asyncio.run(connect["connect"].send(message))

def MessageProcessing(websocket,message):
  # выясняем от кого обрабатываем сообщения
  for connect in clients:
     if connect["connect"] == websocket:
        print(f"IN: {message}")
        SendMessage(connect,"Hello")

# новый клиент
async def OnNewClient(websocket, path):
        requested_protocols = websocket.request_headers['Sec-WebSocket-Protocol']
        patch = path.strip('/')
        print(f"Новый клиент: {requested_protocols},{patch}")
        try:
          pasket = {}
          pasket["connect"] = websocket
          pasket["host"] = websocket.request_headers['Host']
          clients.append(pasket)
          async for message in websocket:
               th = Thread(target=MessageProcessing, args=(websocket,message,))
               th.start()
        except Exception as e:
            exc_type, exc_obj, exc_tb = sys.exc_info()
            fname = os.path.split(exc_tb.tb_frame.f_code.co_filename)[1]
            print(f"Прерывание: {e} ({fname},строка: {exc_tb.tb_lineno})")

        finally:
            print(f"соединение закрыто..")
            for connect in clients:
                if connect["connect"]==websocket:
                    clients.remove(connect)

async def main():
  async with websockets.serve(OnNewClient, "0.0.0.0", 35609,subprotocols=["virtual"]):
    print("сервер стартовал и ждёт клиентов")
    await asyncio.Future()

asyncio.run(main())

#!/usr/bin/env python3

#encoding: utf-8

import asyncio

import sys

import os

import websockets

from threading import Thread

# массив клиентов

clients=[]

# отправляем сообщение

def SendMessage(connect, message):

asyncio.run(connect["connect"].send(message))

def MessageProcessing(websocket,message):

# выясняем от кого обрабатываем сообщения

for connect in clients:

if connect["connect"] == websocket:

print(f"IN: {message}")

SendMessage(connect,"Hello")

# новый клиент

async def OnNewClient(websocket, path):

requested_protocols = websocket.request_headers['Sec-WebSocket-Protocol']

patch = path.strip('/')

print(f"Новый клиент: {requested_protocols},{patch}")

try:

pasket = {}

pasket["connect"] = websocket

pasket["host"] = websocket.request_headers['Host']

clients.append(pasket)

async for message in websocket:

th = Thread(target=MessageProcessing, args=(websocket,message,))

th.start()

except Exception as e:

exc_type, exc_obj, exc_tb = sys.exc_info()

fname = os.path.split(exc_tb.tb_frame.f_code.co_filename)[1]

print(f"Прерывание: {e} ({fname},строка: {exc_tb.tb_lineno})")

finally:

print(f"соединение закрыто..")

for connect in clients:

if connect["connect"]==websocket:

clients.remove(connect)

async def main():

async with websockets.serve(OnNewClient, "0.0.0.0", 35609,subprotocols=["virtual"]):

print("сервер стартовал и ждёт клиентов")

await asyncio.Future()

asyncio.run(main())

Оставить комментарий python, WebSocket, websockets

PHP AMP Websocket: указание произвольных заголовков при рукопожатии

24.08.2022 Павел Грибов PHP

Задача: добавить произвольный заголовок клиенту при рукопожатии с сервером. Например Sec-WebSocket-Protocol

Решение:

use Amp\Delayed;
use Amp\Websocket\Client\Connection;
use Amp\Websocket\Client\Handshake;
use Amp\Websocket\Message;
use function Amp\Websocket\Client\connect;
use Amp\Socket\ClientTlsContext;
use Amp\Socket\ConnectContext;

            Amp\Loop::run(function () use ($wss_url,$ip,$port,$pascket,&$answer,$wait_reseive) {                            
                $tlsc=new ClientTlsContext("");
                $tlw=$tlsc->withoutPeerVerification();
                $connectContext = (new ConnectContext)->withTlsContext($tlw);
                $handshake = (new Handshake("ws://1.18.24.70:$port/virtual_api_1c"))->withHeader('Sec-WebSocket-Protocol', 'virtual');  
                $connection = yield connect($handshake,$connectContext);   
                yield $connection->send($pascket);
                yield $connection->close();
            });

use Amp\Delayed;

use Amp\Websocket\Client\Connection;

use Amp\Websocket\Client\Handshake;

use Amp\Websocket\Message;

use function Amp\Websocket\Client\connect;

use Amp\Socket\ClientTlsContext;

use Amp\Socket\ConnectContext;

Amp\Loop::run(function () use ($wss_url,$ip,$port,$pascket,&$answer,$wait_reseive) {

$tlsc=new ClientTlsContext("");

$tlw=$tlsc->withoutPeerVerification();

$connectContext = (new ConnectContext)->withTlsContext($tlw);

$handshake = (new Handshake("ws://1.18.24.70:$port/virtual_api_1c"))->withHeader('Sec-WebSocket-Protocol', 'virtual');

$connection = yield connect($handshake,$connectContext);

yield $connection->send($pascket);

yield $connection->close();

});

Оставить комментарий amp, handshake, header, Sec-WebSocket-Protocol, websocket client

NetBeans 14 и поддержка Python

18.08.2022 Павел Грибов WEB

Начиная с версии 8.1, python плагины не поддерживаются официально и установить из самой IDE их нельзя, однако неофициальные плагины таки существуют.

Скачать пакет с плагинами можно здесь

Установка: Tools -> Plugins -> Downloaded -> Add Plugins

Оставить комментарий netbeans 14, plugin, python

PostgreSQL: вывод числа в виде значения часы:минуты:секунды

17.08.2022 Павел Грибов WEB

Задача: в одной из колонок хранятся секунды в виде значения int, необходимо при выводе преобразовать их по маске hh:mm:ss

Решение:

TO_CHAR((docs_charge.duration || ' second')::interval, 'HH24:MI:SS') as duration

1	TO_CHAR((docs_charge.duration \|\| ' second')::interval, 'HH24:MI:SS') as duration

Оставить комментарий

« 1 … 47 48 49 50 51 … 293 »

Пн	Вт	Ср	Чт	Пт	Сб	Вс
				1	2	3
4	5	6	7	8	9	10
11	12	13	14	15	16	17
18	19	20	21	22	23	24
25	26	27	28	29	30