Menciptakan Flow ke Dua

Gambaran

Tutorial ini dibangun berdasarkan tutorial pertama untuk membuat aliran yang mulai membawa data dari sumber eksternal untuk melakukan sesuatu yang berguna secara lokal.

Aliran akan:

     Ambil informasi dari situs web secara berkala
     Ubah informasi itu menjadi bentuk yang bermanfaat
     Tampilkan hasilnya di bilah sisi Debug
 



1. Tambahkan simpul Injeksi
Dalam tutorial sebelumnya, Inject node digunakan untuk memicu aliran ketika tombolnya diklik. Untuk tutorial ini, Inject node akan dikonfigurasikan untuk memicu aliran pada interval reguler.

Seret simpul Suntikkan ke ruang kerja dari palet.

Klik dua kali node untuk memunculkan dialog edit. Atur interval pengulangan ke setiap 5 menit.

Klik Selesai untuk menutup dialog.
 
2. Tambahkan node Permintaan HTTP

Node Permintaan HTTP dapat digunakan untuk mengambil halaman web saat dipicu.

Setelah menambahkan satu ke ruang kerja, edit untuk mengatur properti URL ke:

https://earthquake.usgs.gov/earthquakes/feed/v1.0/summary/significant_month.csv

Kemudian klik Selesai untuk menutup dialog.

URL ini adalah umpan gempa bumi yang signifikan dalam sebulan terakhir dari situs web Survei Geologi AS. Situs ini menawarkan sejumlah opsi lain yang mungkin ingin Anda mainkan setelah menyelesaikan tutorial ini.

3. Tambahkan simpul CSV

Tambahkan simpul CSV dan edit propertinya. Aktifkan opsi untuk ‘Baris pertama berisi nama kolom’.

Lalu klik Selesai untuk menutup.

4. Tambahkan simpul Debug

Tambahkan simpul Debug ke output.

5. Sambungkan semuanya

Tambahkan kabel yang menghubungkan:

    Inject node output ke input node HTTP Request.
    Node HTTP Request menampilkan ke input node CSV.
    Node CSV menghasilkan ke input simpul Debug.

7. Tambahkan simpul Switch

Tambahkan node Switch ke ruang kerja. Edit propertinya dan konfigurasikan untuk memeriksa properti msg.payload.mag dengan uji> = ubah untuk menguji angka dan nilainya 7. Klik Selesai untuk menutup.

Tambahkan kabel kedua dari simpul CSV ke simpul Switch ini.

8. Tambahkan simpul Ubah

Tambahkan Ubah node, kabel ke output dari Switch node. Konfigurasikan untuk mengatur msg.payload ke string PANIC !.

9. Tambahkan simpul Debug

Kawat simpul Debug baru ke output dari simpul Ubah

10. Menyebarkan

Menyebarkan aliran ke runtime dengan mengklik tombol Deploy.

Dengan tab sidebar Debug terbuka klik tombol Suntikkan. Anda akan melihat daftar entri dengan beberapa konten yang terlihat seperti:

msg.payload : Object
{"time":"2017-11-19T15:09:03.120Z","latitude":-21.5167,"longitude":168.5426,"depth":14.19,"mag":6.6,"magType":"mww","gap":21,"dmin":0.478,"rms":0.86,"net":"us","id":"us2000brgk","updated":"2017-11-19T17:10:58.449Z","place":"68km E of Tadine, New Caledonia","type":"earthquake","horizontalError":6.2,"depthError":2.8,"magError":0.037,"magNst":72,"status":"reviewed","locationSource":"us","magSource":"us"} 

Anda sekarang dapat mengklik panah kecil di sebelah kiri setiap properti untuk mengembangkannya dan memeriksa isinya

Jika ada gempa dengan kekuatan lebih dari 7 Anda juga akan melihat pesan debug seperti:

msg.payload : string(6)
"PANIC!"  

Anda dapat mengubah nilai sakelar 7 ke yang lebih kecil untuk menguji program Anda. Ingatlah untuk mengklik deploy setelah perubahan. ***
 
Ringkasan

Aliran ini dipicu secara otomatis setiap 5 menit dan mengambil data dari url. Ini mem-parsing data dan menampilkan di bilah sisi Debug. Itu juga memeriksa nilai magnitude dalam data dan cabang aliran untuk setiap pesan dengan magnitude lebih besar dari, atau sama dengan, 7. Muatan pesan tersebut dimodifikasi dan ditampilkan di sidebar Debug.
 
Sumber

Alur yang dibuat dalam tutorial ini diwakili oleh json berikut. Untuk mengimpornya ke editor, salin ke clipboard Anda dan kemudian rekatkan ke dialog Impor.

[{"id":"e36406f2.8ef798","type":"inject","z":"f03b57d5.e525f8","name":"","topic":"","payload":"","payloadType":"str","repeat":"300","crontab":"","once":false,"x":130,"y":900,"wires":[["c3c50023.3bbed"]]},{"id":"c3c50023.3bbed","type":"http request","z":"f03b57d5.e525f8","name":"Recent Quakes","method":"GET","url":"https://earthquake.usgs.gov/earthquakes/feed/v1.0/summary/significant_month.csv","tls":"","x":300,"y":900,"wires":[["8afc6cac.e0812"]]},{"id":"8afc6cac.e0812","type":"csv","z":"f03b57d5.e525f8","name":"","sep":",","hdrin":true,"hdrout":"","multi":"one","ret":"\\n","temp":"","x":470,"y":900,"wires":[["44779781.4190f8","6f0eb546.9e208c"]]},{"id":"44779781.4190f8","type":"debug","z":"f03b57d5.e525f8","name":"","active":true,"complete":false,"x":630,"y":900,"wires":[]},{"id":"6f0eb546.9e208c","type":"switch","z":"f03b57d5.e525f8","name":"","property":"payload.mag","propertyType":"msg","rules":[{"t":"gte","v":"7","vt":"num"}],"checkall":"true","outputs":1,"x":510,"y":960,"wires":[["d78d4aa8.8c8208"]]},{"id":"d78d4aa8.8c8208","type":"change","z":"f03b57d5.e525f8","name":"","rules":[{"t":"set","p":"payload","pt":"msg","to":"PANIC!","tot":"str"}],"action":"","property":"","from":"","to":"","reg":false,"x":650,"y":1020,"wires":[["72fddece.fac0d"]]},{"id":"72fddece.fac0d","type":"debug","z":"f03b57d5.e525f8","name":"","active":true,"complete":false,"x":750,"y":960,"wires":[]}]