Гость
Войти | Профиль | Очистить
Действия ...
Форумы / PHP, Perl, Python [игнор отключен] [закрыт для гостей] / python/ websocket реализация отправки сообщений клиенту, который держит сокет открытым / 8 сообщений из 8, страница 1 из 1
03.12.2021, 15:28
    #40117069
try_except
try_except
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
python/ websocket реализация отправки сообщений клиенту, который держит сокет открытым
Добрый день.
Помогите разобраться, как правильно реализовать.
Суть: Клиент - зарядные станции, которые подключаются открывают сокет и отправляю на сервер сообщения и получают ответы.
Сервер - слушает порт, видит подключенную станцию, принимает сообщения и отправляет на них ответы.
Вопрос: Когда клиент подключается и присылает headers я могу отправить сообщение клиенту. Но мне нужно, отправлять периодически сообщения клиенту, который держит открытым сокет, не понимаю, как это реализовать. Может кто-то подскажет?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
03.12.2021, 15:38
    #40117073
try_except
try_except
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
python/ websocket реализация отправки сообщений клиенту, который держит сокет открытым
пример кода отправки:

Код: python
1.
2.
3.
4.
5.
6.
7.
    charge_point_id = path.strip('/')
    cp = client_main(charge_point_id, websocket)
    logging.info(charge_point_id)
    print(charge_point_id)
    print(path)
    await websocket.send(json.dumps([2,"222", "GetLocalListVersion", {}]))
    await cp.start()
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
03.12.2021, 15:39
    #40117074
try_except
try_except
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
python/ websocket реализация отправки сообщений клиенту, который держит сокет открытым
пример получения сообщения от клиента:

Код: python
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
class client_main(cp):

        errors = False
            
        if not errors:
            
                        
            @on('BootNotification')
            def on_boot_notitication(self,    charge_point_vendor, charge_point_model,charge_point_serial_number,firmware_version, 
                                     meter_type, **kwargs):
               return call_result.BootNotificationPayload(
                    status="Accepted",
                    current_time=date_str.replace('+00:00','Z'),
                    interval=60
                )
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.12.2021, 15:23
    #40117360
iot
iot
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
python/ websocket реализация отправки сообщений клиенту, который держит сокет открытым
try_except,

добрый день,

попробуйте не on_boot, а heartbeat https://github.com/mobilityhouse/ocpp/blob/ab04d52cc5fc5f447c3683c78839fee9cdadb9ce/examples/v201/central_system.py#L32
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
06.12.2021, 08:50
    #40117650
try_except
try_except
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
python/ websocket реализация отправки сообщений клиенту, который держит сокет открытым
iot,
я получаю heartbeat и в ответ отправляю время.
Но как я могу, запросить другие команды, например: reservenow, reset и т.д.?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
06.12.2021, 09:00
    #40117655
iot
iot
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
python/ websocket реализация отправки сообщений клиенту, который держит сокет открытым
try_except
iot,
я получаю heartbeat и в ответ отправляю время.
Но как я могу, запросить другие команды, например: reservenow, reset и т.д.?

Код: python
1.
2.
3.
    @on('Heartbeat')
    def on_reset(self):
        #my reset code there
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
06.12.2021, 12:39
    #40117723
try_except
try_except
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
python/ websocket реализация отправки сообщений клиенту, который держит сокет открытым
iot, так мне нужно на heatrbeat оправить время.
Вы предлагаете, таким образом?

Код: python
1.
2.
3.
4.
5.
6.
7.
@on('Heartbeat')
    def on_getlocallistversion(self):
    await self.route_message(json.dumps([2,"222","GetLocalListVersion",{}]))
    def on_hearbeat(self):
        return call_result.HeartbeatPayload(
                    current_time=datetime.utcnow().strftime('%Y-%m-%dT%H:%M:%S')+"Z"
       )
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
07.12.2021, 10:05
    #40118004
iot
iot
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
python/ websocket реализация отправки сообщений клиенту, который держит сокет открытым
try_except
iot, так мне нужно на heatrbeat оправить время.
Вы предлагаете, таким образом?

Код: python
1.
2.
3.
4.
5.
6.
7.
@on('Heartbeat')
    def on_getlocallistversion(self):
    await self.route_message(json.dumps([2,"222","GetLocalListVersion",{}]))
    def on_hearbeat(self):
        return call_result.HeartbeatPayload(
                    current_time=datetime.utcnow().strftime('%Y-%m-%dT%H:%M:%S')+"Z"
       )


судя по примерам https://github.com/mobilityhouse/ocpp/blob/ab04d52cc5fc5f447c3683c78839fee9cdadb9ce/examples/v201/charge_point.py выглядит так:
Код: python
1.
2.
3.
4.
5.
    async def send_heartbeat(self, interval):
        request = call.HeartbeatPayload()
        while True:
            await self.call(request)
            await asyncio.sleep(interval)


требуемый reguest выбираете видимо здесь https://github.com/mobilityhouse/ocpp/blob/ab04d52cc5fc5f447c3683c78839fee9cdadb9ce/ocpp/v20/call.py или реализуете свой по образу и подобию
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
Форумы / PHP, Perl, Python [игнор отключен] [закрыт для гостей] / python/ websocket реализация отправки сообщений клиенту, который держит сокет открытым / 8 сообщений из 8, страница 1 из 1
Целевая тема:
Создать новую тему:
Автор:
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение
созд. / загр.: 382ms
Закрыть
start [/forum/topic.php?fid=23&mobile=1&tid=1459399]:
 0ms
get settings:
 9ms
get forum list:
 13ms
check forum access:
 3ms
check topic access:
 3ms
track hit:
 37ms
get topic data:
 13ms
get forum data:
 3ms
get page messages:
 40ms
get tp. blocked users:
 2ms
others: 259ms
total:  382ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]