- Покрывает весь функционал Pepeunit.
- Поддерживает Компилируемые и Интерпритируемые обновления.
- Используется для Интеграционных тестов.
Python >3.9
Интерпритируемый Компилируемый
any Desktop
- Desktop
{
"DELAY_PUB_MSG": 1,
"PEPEUNIT_URL": "unit.example.com",
"HTTP_TYPE": "https",
"MQTT_URL": "emqx.example.com",
"MQTT_PORT": 1883,
"PEPEUNIT_TOKEN": "jwt_token",
"SYNC_ENCRYPT_KEY": "",
"SECRET_KEY": "32_bit_secret_key",
"PING_INTERVAL": 30,
"STATE_SEND_INTERVAL": 300
}
DELAY_PUB_MSG
- частота отправки данных вoutput_topic
в секундах
{
"input_base_topic": [
"update/pepeunit",
"schema_update/pepeunit"
],
"output_base_topic": [
"state/pepeunit"
],
"input_topic": [
"input/pepeunit"
],
"output_topic": [
"output/pepeunit"
]
}
input
input/pepeunit
- принимает в качестве значения натуральные числа, записывает их вlog.json
. После записи, отправляет полученное число вoutput_topic
output
output/pepeunit
- отправляет сообщение в формате:message: N
, гдеN
- остаток от деления на10
, числа циклов отправки сообщений вoutput/pepeunit
Алгоритм работы с момента запуска через entrypoint.sh
:
- Подключение к
MQTT Брокеру
- Подписка на
input
топики - Каждые
DELAY_PUB_MSG
секунд публикуются сообщения вoutput/pepeunit
Алгоритм работы в момент получения сообщения из input/pepeunit
- Полученный текст преобразуется в число
- Число записывается в
log.json
в формате{"value": 1, "input_topic": "example.com/dc2d6f5e-90b3-4cdb-91a4-5ae12db1887f/pepeunit"}
- Число преобразуется в строку и отправляется в
output/pepeunit