Otwórz Node-RED Zaimportuj poniższy przepływ Schemat licznika obserwujących na Instagramie w Node-RED 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 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 [ { "id": "8b28f036a227d636", "type": "group", "z": "e9b8998ad5b3fa7d", "name": "", "style": { "label": true }, "nodes": [ "49ae0cc4d71fd031", "66c430817f82be55", "7f41a9f67a7b1e70", "74be1866413b2aa6", "34f297b864caf6db" ], "x": 194, "y": 159, "w": 832, "h": 122 }, { "id": "49ae0cc4d71fd031", "type": "inject", "z": "e9b8998ad5b3fa7d", "g": "8b28f036a227d636", "name": "Every 12 hours", "props": [], "repeat": "43200", "crontab": "", "once": false, "onceDelay": "2", "topic": "", "x": 320, "y": 240, "wires": [ [ "66c430817f82be55" ] ] }, { "id": "66c430817f82be55", "type": "http request", "z": "e9b8998ad5b3fa7d", "g": "8b28f036a227d636", "name": "", "method": "GET", "ret": "obj", "paytoqs": "query", "url": "https://i.instagram.com/api/v1/users/web_profile_info/?username=sysadmin.info.pl", "tls": "", "persist": false, "proxy": "", "insecureHTTPParser": false, "authType": "", "senderr": false, "headers": [ { "keyType": "other", "keyValue": "user-agent", "valueType": "other", "valueValue": "Instagram 76.0.0.15.395 Android (24/7.0; 640dpi; 1440x2560; samsung; SM-G930F; herolte; samsungexynos8890; en_US; 138226743)" } ], "x": 490, "y": 240, "wires": [ [ "7f41a9f67a7b1e70" ] ] }, { "id": "7f41a9f67a7b1e70", "type": "function", "z": "e9b8998ad5b3fa7d", "g": "8b28f036a227d636", "name": "parser", "func": "// Store the incoming message payload in a variable 'json'.\nvar json = msg.payload;\n\n// Check if 'json' and the nested properties 'json.data.user.edge_followed_by' exist.\n// This is to ensure that the specific structure is present in the payload.\nif (json && json.data && json.data.user && json.data.user.edge_followed_by) {\n // Extract the subscriber count from the nested JSON structure.\n var subscriberCount = json.data.user.edge_followed_by.count;\n\n // Modify the message payload to include the subscriber count and additional properties.\n // Here, three properties are set:\n // 'text': a string representation of the subscriber count.\n // 'icon': a static string indicating the icon to be used, in this case, 'instagram'.\n // 'duration': a static value indicating the duration, set to 10 seconds.\n msg.payload = {\n \"text\": subscriberCount.toString(), // Convert the subscriber count to a string.\n \"icon\": \"instagram\", // Set the icon property to 'instagram'.\n \"duration\": 10 // Set the duration property to 10 seconds.\n };\n} else {\n // This block executes if the expected data structure is not present in the payload.\n // It sets the payload to a predefined object indicating that data is not available.\n msg.payload = { \"text\": \"Data not available\" };\n}\n\n// Return the modified message object.\n// This is essential for the function node to pass the message to the next node in the flow.\nreturn msg;", "outputs": 1, "timeout": "", "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 630, "y": 240, "wires": [ [ "74be1866413b2aa6" ] ] }, { "id": "74be1866413b2aa6", "type": "mqtt out", "z": "e9b8998ad5b3fa7d", "g": "8b28f036a227d636", "name": "", "topic": "awtrix_b6d76c/custom/instagram", "qos": "", "retain": "", "respTopic": "", "contentType": "", "userProps": "", "correl": "", "expiry": "", "broker": "346df2a95aac5785", "x": 860, "y": 240, "wires": [] }, { "id": "34f297b864caf6db", "type": "comment", "z": "e9b8998ad5b3fa7d", "g": "8b28f036a227d636", "name": "Instagram", "info": "ATTENTION:\nTrigger this node as rarely as possible!\nChange your username in the http request node URL", "x": 300, "y": 200, "wires": [] }, { "id": "346df2a95aac5785", "type": "mqtt-broker", "name": "MQTT HA Broker", "broker": "10.10.0.100", "port": "1883", "clientid": "", "autoConnect": true, "usetls": false, "protocolVersion": "4", "keepalive": "60", "cleansession": true, "autoUnsubscribe": true, "birthTopic": "awtrix_b6d76c", "birthQos": "2", "birthRetain": "true", "birthPayload": "", "birthMsg": {}, "closeTopic": "awtrix_b6d76c", "closeQos": "2", "closeRetain": "true", "closePayload": "", "closeMsg": {}, "willTopic": "awtrix_b6d76c", "willQos": "2", "willRetain": "true", "willPayload": "", "willMsg": {}, "userProps": "", "sessionExpiry": "" } ] Zmień swoją nazwę użytkownika w adresie URL węzła żądania HTTP Zmień adres IP swojego brokera MQTT Zmień prefiks w temacie (zobacz film, aby dowiedzieć się, o czym mówię) Pobierz ikonę Instagram stąd: Instagram icon Prześlij ikonę do urządzenia Ulanzi za pośrednictwem pulpitu nawigacyjnego. (Zobacz wideo). Wdróż (deploy) schemat. Uruchom węzeł inject jeden raz. Uruchamiaj ten węzeł jak najrzadziej! Czasomierz jest ustawiony na pobieranie danych co 12 godzin.

Wprowadzenie do aplikacji Pomodoro Timer w Node-RED W dziedzinie narzędzi zwiększających produktywność, Technika Pomodoro wyróżnia się jako powszechnie stosowana metoda zwiększania koncentracji i wydajności. Dostrzegając potencjał tej techniki, opracowaliśmy kompleksową aplikację Pomodoro Timer przy użyciu Node-RED, narzędzia programistycznego opartego na schemacie. Ta aplikacja to nie tylko prosty licznik czasu; to wieloaspektowe narzędzie, które integruje nowoczesne technologie internetowe i protokoły komunikacyjne Internetu rzeczy (IoT), aby zapewnić bogate, interaktywne wrażenia użytkownika. ...

Skopiuj schemat 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 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 [ { "id": "work-timer-start", "type": "inject", "z": "305da690670f67c0", "name": "Start Work Timer", "props": [{"p": "payload"}], "repeat": "", "crontab": "", "once": false, "topic": "", "payload": "", "payloadType": "date", "x": 100, "y": 100, "wires": [["work-timer-function"]] }, { "id": "work-timer-function", "type": "function", "z": "305da690670f67c0", "name": "Countdown Timer", "func": "var duration = 25 * 60; // 25 minutes in seconds\nfunction countdown() {\n if (flow.get('workTimerRunning') === false) {\n return;\n }\n var message = {\n payload: {\n text: 'Time left: ' + duration + ' sec',\n icon: \"82\",\n color: '#FFA500',\n duration: 1500\n }\n };\n node.send(message);\n duration--;\n if (duration >= 0) {\n setTimeout(countdown, 1000);\n } else {\n var endMessage = {\n payload: {\n text: 'Work Period Ended',\n icon: \"29802\",\n color: '#00FF00',\n duration: 20\n }\n };\n node.send(endMessage);\n }\n}\nflow.set('workTimerRunning', true);\ncountdown();\nreturn null;", "outputs": 1, "x": 300, "y": 100, "wires": [["mqtt-out-work"]] }, { "id": "mqtt-out-work", "type": "mqtt out", "z": "305da690670f67c0", "name": "MQTT Work Timer", "topic": "awtrix_b6d76c/custom/work_timer", "broker": "346df2a95aac5785", "x": 500, "y": 100, "wires": [] }, { "id": "work-timer-stop", "type": "inject", "z": "305da690670f67c0", "name": "Stop Work Timer", "props": [{"p": "payload"}], "repeat": "", "crontab": "", "once": false, "topic": "", "payload": "stop", "payloadType": "str", "x": 100, "y": 160, "wires": [["stop-work-timer-function"]] }, { "id": "stop-work-timer-function", "type": "function", "z": "305da690670f67c0", "name": "Stop Work Timer Function", "func": "flow.set('workTimerRunning', false);\nvar message = {\n payload: {\n text: 'Work Timer Stopped',\n icon: \"29802\",\n color: '#FF0000',\n duration: 20\n }\n};\nreturn message;", "outputs": 1, "x": 300, "y": 160, "wires": [["mqtt-out-work"]] }, { "id": "break-timer-start", "type": "inject", "z": "305da690670f67c0", "name": "Start Break Timer", "props": [{"p": "payload"}], "repeat": "", "crontab": "", "once": false, "topic": "", "payload": "", "payloadType": "date", "x": 100, "y": 200, "wires": [["break-timer-function"]] }, { "id": "break-timer-function", "type": "function", "z": "305da690670f67c0", "name": "Break Countdown Timer", "func": "var duration = 5 * 60; // 5 minutes in seconds\nfunction countdown() {\n if (flow.get('breakTimerRunning') === false) {\n return;\n }\n var message = {\n payload: {\n text: 'Break time left: ' + duration + ' sec',\n icon: \"6396\",\n color: '#FFA500',\n duration: 300\n }\n };\n node.send(message);\n duration--;\n if (duration >= 0) {\n setTimeout(countdown, 1000);\n } else {\n var endMessage = {\n payload: {\n text: 'Break Period Ended',\n icon: \"29802\",\n color: '#00FF00',\n duration: 20\n }\n };\n node.send(endMessage);\n }\n}\nflow.set('breakTimerRunning', true);\ncountdown();\nreturn null;", "outputs": 1, "x": 300, "y": 200, "wires": [["mqtt-out-break"]] }, { "id": "mqtt-out-break", "type": "mqtt out", "z": "305da690670f67c0", "name": "MQTT Break Timer", "topic": "awtrix_b6d76c/custom/break_timer", "broker": "346df2a95aac5785", "x": 500, "y": 200, "wires": [] }, { "id": "break-timer-stop", "type": "inject", "z": "305da690670f67c0", "name": "Stop Break Timer", "props": [{"p": "payload"}], "repeat": "", "crontab": "", "once": false, "topic": "", "payload": "stop", "payloadType": "str", "x": 100, "y": 260, "wires": [["stop-break-timer-function"]] }, { "id": "stop-break-timer-function", "type": "function", "z": "305da690670f67c0", "name": "Stop Break Timer Function", "func": "flow.set('breakTimerRunning', false);\nvar message = {\n payload: {\n text: 'Break Timer Stopped',\n icon: \"29802\",\n color: '#FF0000',\n duration: 20\n }\n};\nreturn message;", "outputs": 1, "x": 300, "y": 260, "wires": [["mqtt-out-break"]] } ] Zmień prefix awtrix_b6d76c na własny. ...

Oto krótki film; czytaj dalej, aby dowiedzieć się więcej. Zalecam obejrzenie całego filmu, aby zrozumieć, jak wszystko zostało zrobione i wdrożone. W poprzednim samouczku Jak wdrożyć n8n w Kubernetes - k3s wdrożyłem n8n. Sprawdziłem, że wszystko działa poprawnie. 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 kubectl get all -n n8n NAME READY STATUS RESTARTS AGE pod/postgres-statefulset-0 1/1 Running 0 23h pod/n8n-deployment-6dfd7cc794-pgccd 1/1 Running 0 23h NAME TYPE CLUSTER-IP EXTERNAL-IP PORT(S) AGE service/postgres-service ClusterIP None <none> 5432/TCP 23h service/n8n-service NodePort 10.43.216.21 <none> 80:32469/TCP 23h NAME READY UP-TO-DATE AVAILABLE AGE deployment.apps/n8n-deployment 1/1 1 1 23h NAME DESIRED CURRENT READY AGE replicaset.apps/n8n-deployment-6dfd7cc794 1 1 1 23h NAME READY AGE statefulset.apps/postgres-statefulset 1/1 23h Jedna osoba (ona lub on) zostawiła komentarz pod moim krótkim filmem ...

Oto krótki film; czytaj dalej, aby dowiedzieć się więcej. Kontroler NGINX Ingress w Kubernetes można najlepiej zrozumieć jako wyspecjalizowaną wersję narzędzia Ingress. To jak wysoce wykwalifikowany recepcjonista przy głównym wejściu do budynku mieszkalnego, wyposażony w dodatkowe możliwości i ekspertyzę. wysoce wykwalifikowany recepcjonista ...

Oto krótki film; czytaj dalej, aby dowiedzieć się więcej. W Kubernetes Ingress to narzędzie zarządzające dostępem zewnętrznym do usług w klastrze, głównie dla ruchu HTTP i HTTPS. Działa jako kontroler kierujący zewnętrzne żądania do wewnętrznych usług. (Reszta artykułu znajduje się pod obrazkiem.) recepcja Aby zrozumieć Ingress, można go porównać do głównego wejścia lub recepcji w budynku mieszkalnym. Podobnie jak recepcja kieruje gości do różnych mieszkań w zależności od tego, kogo chcą zobaczyć, Ingress kieruje przychodzący ruch zewnętrzny do odpowiednich usług w klastrze Kubernetes. ...

Oto krótki film; czytaj dalej, aby dowiedzieć się więcej. W Kubernetes “Port” i “TargetPort” to kluczowe ustawienia w usłudze (Service), które kontrolują sposób kierowania ruchu sieciowego do podów. (Reszta artykułu znajduje się pod obrazkiem). wewnętrzny system telefoniczny Port: Odnosi się do numeru portu w samej usłudze. Jest to punkt kontaktowy dla innych usług lub użytkowników zewnętrznych, gdy chcą komunikować się z podami zarządzanymi przez tę usługę. ...

Oto krótki film; czytaj dalej, aby dowiedzieć się więcej. NodePort to typ usługi w Kubernetes, która umożliwia dostęp do poda z zewnątrz klastra Kubernetes. To jak otwarcie konkretnego kanału dla ruchu zewnętrznego, aby dotrzeć do twoich podów. (Reszta artykułu znajduje się pod obrazem.) wrzutnik na listy ...

Oto krótki film; czytaj dalej, aby dowiedzieć się więcej. W Kubernetes serwis to kluczowe pojęcie, działające jak brama lub recepcjonista dla podów. Jest to sposób, w jaki Kubernetes udostępnia pody, zarówno innym podom w tym samym klastrze, jak i zewnętrznym użytkownikom oraz systemom. (Reszta artykułu znajduje się pod obrazem.) ...

Oto krótkie wideo; czytaj dalej, aby dowiedzieć się więcej. W kontekście Kubernetes, pod można postrzegać jako najmniejszą jednostkę wdrożeniową, podobną do pojedynczego mieszkania w dużym bloku mieszkalnym. (Reszta artykułu znajduje się pod obrazkiem.) duży blok mieszkalny Tak jak mieszkanie może mieć jeden lub więcej pokoi, pod może zawierać jeden lub więcej kontenerów, takich jak kontenery Docker. Te kontenery wewnątrz pod są jak pokoje w mieszkaniu, każdy z nich służy określonej funkcji lub celowi. Dzielą zasoby i są zarządzane jako pojedyncza jednostka. ...