###Gtk3アプリ NodeRedで仮想通貨を表示する その２
####仮想通貨の価格をチャートに表示する
node-red-dashboardをインストールします。
node-red-dashboard
####学習動画
####パラメーター設定
topicとpayloadを追加します。
{topic:"temperature", payload:22}
####全体図
####Flow図
[{"id":"5fb94a5f12d9b343","type":"tab","label":"フロー 3","disabled":false,"info":"","env":[]},{"id":"c51cb05a05f0bbd0","type":"ui_chart","z":"5fb94a5f12d9b343","name":"","group":"bbc543c8094bb4ea","order":1,"width":0,"height":0,"label":"chart","chartType":"line","legend":"false","xformat":"HH:mm:ss","interpolate":"linear","nodata":"","dot":false,"ymin":"0","ymax":"2","removeOlder":1,"removeOlderPoints":"","removeOlderUnit":"3600","cutout":0,"useOneColor":false,"useUTC":false,"colors":["#1f77b4","#aec7e8","#ff7f0e","#2ca02c","#98df8a","#d62728","#ff9896","#9467bd","#c5b0d5"],"outputs":1,"useDifferentColor":false,"className":"","x":590,"y":180,"wires":[[]]},{"id":"d41012e0b93c34ec","type":"binance-get-price","z":"5fb94a5f12d9b343","name":"","ticker":"BNBBTC","x":180,"y":100,"wires":[["fbb0fe65d9a45fad"]]},{"id":"60a6820af7cee079","type":"debug","z":"5fb94a5f12d9b343","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"true","targetType":"full","statusVal":"","statusType":"auto","x":590,"y":100,"wires":[]},{"id":"e63a8a5503a5a6e7","type":"inject","z":"5fb94a5f12d9b343","name":"","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":false,"onceDelay":"1","topic":"","payloadType":"date","x":130,"y":40,"wires":[["d41012e0b93c34ec"]]},{"id":"fbb0fe65d9a45fad","type":"function","z":"5fb94a5f12d9b343","name":"","func":"msg.topic = \"temperature\";\n\nvar obj = {\n \"topic\":msg.topic, \n \"payload\":msg.payload, \n \"_msgid\":msg._msgid \n};\n\nmsg.tmp = JSON.stringify(obj); \n\nmsg.tmp = encodeURI(msg.tmp);\n\n\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":380,"y":180,"wires":[["c51cb05a05f0bbd0","60a6820af7cee079","56dbaafa99bbf7bd","019b328ad992a833"]]},{"id":"56dbaafa99bbf7bd","type":"exec","z":"5fb94a5f12d9b343","command":"nodeSqlApp","addpay":"tmp","append":"","useSpawn":"false","timer":"","winHide":false,"oldrc":false,"name":"exe","x":130,"y":280,"wires":[["8d821d5df7a19461"],["fce4cb380b7057d8"],["47ffb0fb6b305d87"]]},{"id":"8d821d5df7a19461","type":"debug","z":"5fb94a5f12d9b343","name":"標準出力","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"payload","targetType":"msg","statusVal":"","statusType":"auto","x":310,"y":280,"wires":[]},{"id":"fce4cb380b7057d8","type":"debug","z":"5fb94a5f12d9b343","name":"標準エラー出力","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"payload","targetType":"msg","statusVal":"","statusType":"auto","x":330,"y":340,"wires":[]},{"id":"47ffb0fb6b305d87","type":"debug","z":"5fb94a5f12d9b343","name":"返却コード","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"payload","targetType":"msg","statusVal":"","statusType":"auto","x":310,"y":400,"wires":[]},{"id":"019b328ad992a833","type":"func-exec","z":"5fb94a5f12d9b343","name":"","func":"var command = 'nodeSqlApp ' + msg.tmp;\n\nvar exec = child_process.exec(command, (error, stdout, stderr) => { \n if (error) { \n node.error(`exec error: ${error}`); \n return; \n } \n node.error(`stdout: ${stdout}`); \n node.error(`stderr: ${stderr}`); \n msg.payload = stdout;\n callback(msg);\n}); \nreturn msg;","outputs":1,"noerr":0,"x":570,"y":280,"wires":[["3da616399aedc082"]]},{"id":"3da616399aedc082","type":"debug","z":"5fb94a5f12d9b343","name":"標準出力","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"true","targetType":"full","statusVal":"","statusType":"auto","x":720,"y":280,"wires":[]},{"id":"bbc543c8094bb4ea","type":"ui_group","name":"デフォルト","tab":"af105c0b8ff4ec1a","order":1,"disp":true,"width":"6","collapse":false,"className":""},{"id":"af105c0b8ff4ec1a","type":"ui_tab","name":"ホーム","icon":"dashboard","disabled":false,"hidden":false}]
####取得したデータをC#側で保存する
execノードを使ってC#コンソールアプリを実行します。Jsonを引数に渡します。
Sqliteに保存します。
引き渡すJsonは必ずURLエンコードします。
####functionノード
msg.topic = "temperature";
var obj = {
"topic":msg.topic,
"payload":msg.payload,
"_msgid":msg._msgid
};
msg.tmp = JSON.stringify(obj);
//エンコードする
msg.tmp = encodeURI(msg.tmp);
return msg;
#####func-execで実行する場合
var command = '/nodeSqlApp ' + msg.tmp;
var exec = child_process.exec(command, (error, stdout, stderr) => {
if (error) {
node.error(`exec error: ${error}`);
return;
}
node.error(`stdout: ${stdout}`);
node.error(`stderr: ${stderr}`);
msg.payload = stdout;
callback(msg);
});
return msg;
####C#コンソールアプリ側 プログラムの解説
引数で受けたJsonデーターは必ずエンコード、デコードします。
static void Main(string[] args)
{
//必ずデーコードする
var jesonStr = System.Web.HttpUtility.UrlDecode(args[0]);
}
Jsonをモデルに変換します。DepperExtensionを使いModelのままInsertします。
test.cs
BinancePriceModel BinancePriceModel1 = JsonSerializer.Deserialize<BinancePriceModel>(jsonStr);
con.Insert<BinancePriceModel>(BinancePriceModel1);
レコード数を表示します。
string sql = "select * from BinancePriceTable;";
var testResult = con.QueryAsync<BinancePriceModel>(sql);
Console.WriteLine("書き込み数" + testResult.Result.Count());
Dapperが生成するSQLのテーブル名を変更するため、ClassMapperを使います。
public class BinancePriceModelMap : ClassMapper<BinancePriceModel>
{
public BinancePriceModelMap()
{
base.Table("BinancePriceTable");
base.AutoMap();
}
}
C#とFlowデータをGitに上げました。
####参考
https://qiita.com/kuraoka/items/2e14bc2fefb9b0183cc7
https://qiita.com/HiroyasuNishiyama/items/2433d275c667bc75ed8c
https://qiita.com/takeyan/items/fff5e8d64da25220a0c0
https://qiita.com/youtoy/items/61e4a6c9061d68f09e3b
####バイナンスとは
世界最大の仮想通貨取引所です。
バイナンスノードを利用するにはユーザー登録する必要があります。
