サードパーティのデータ サプライヤーはデータと Python を一緒にカプセル化しており、データ クエリは Python メソッドを呼び出すことによってのみ実装できます。Python メソッド呼び出しを単純な Node カプセル化によって実装できれば、すぐに起動でき、開発コストを節約できます。 最も単純かつ大雑把な通信方法は、Nodejs が Python スクリプトを呼び出して、子プロセスの出力を取得することです。ただし、Python を起動してその都度データ パケットをロードするプロセスは比較的長いため、このプロセスは最適化されています。 プロセスコミュニケーションインデックス.py # カプセル化された Python パッケージ、サイズが大きい from mb import MB # データパケットからのクエリ mbe.get('1.0.1.0') インデックス const { spawn } = require('child_process'); python3 を ls で生成します。 ls.stdout.on('データ', (データ) => { console.log(`stdout: ${data}`); }); ls.stderr.on('データ', (データ) => { コンソールエラー(`stderr: ${data}`); }); ls.on('close', (コード) => { console.log(`子プロセスはコード $[code] で終了しました`); }); child_process.spawn を使用して Python サブプロセスを生成し、stdout 出力をリッスンします。上記の方法は公式ドキュメントの例でもあります。現在、この例には 2 つの問題があります。
プロセス間の双方向通信データを一度ロードして複数回使用できることを保証するための前提は、Python プロセスが開始後に終了できないことです。 Python プロセスが終了する理由は、何もすることがないからなので、一般的な方法としては、ループ、スリープ、ポートのリッスンなどがあります。これらの方法は、同期ブロッキングタスクと同期ノンブロッキングタスクに変換できます。このうち最もコストがかからないのは、同期ノンブロッキングタスクです。すると、Linux の select と epoll が考えられます。Python の epoll を簡単に検索したところ、ネイティブパッケージがあるようです。 index.py - epoll 経由で stdin をリッスンします インポートシステム fcntl をインポートする インポート選択 mbからインポートMB jsonをインポート mbe = MB('./データ') # epoll モデル fd = sys.stdin.fileno() epoll = select.epoll() epoll.register(fd、select.EPOLLIN) 関数は、 試す: 真の場合: events = epoll.poll(10) # 同期非ブロッキングデータ = '' fileno、events 内の event の場合: data += sys.stdin.readline() # data == '' または data == '\n' の場合、標準入力からデータを取得します。 続く items = xxx # アイテム内のアイテムの数値処理: 結果 = mbe.get(アイテム) sys.stdout.write(json.dumps(result, ensure_ascii=False) +'\n') # 標準出力に書き込むsys.stdout.flush() # バッファを更新最後に: epoll.unregister(fd) epoll.close() index.js - stdin 経由でデータを送信する 定数 child_process = require('child_process'); python3 の子プロセスを作成します。 コールバックを [] とします。 チャンク=Buffer.alloc(0), チャンクArr = [], データ = ''、 onwork = false; // バッファは動的に拡張できません child.stdout.on('data', (chunk) => { chunkArr.push(チャンク) if (onwork) 戻り値; オンワーク = true; while(chunkArr.length) { チャンク = Buffer.concat([チャンク、chunkArr.pop()]); 定数長さ = チャンク.長さ; trunkAt = -1 とします。 for(const [k, d] of chunks.entries()) { if (d == '0x0a') { // 0a で終了 data += chunks.slice(trunkAt+1, trunkAt=k); const cb = コールバック.shift(); cb(null, データ === 'null' ? null : データ ) データ = ''; } } トランクサイズ < 長さの場合 チャンク = chunks.slice(trunkAt+1) } } オンワーク = false; }) 間隔を設定する(() => { if (callbacks.length) child.stdin.write(`\n`); // Nodejs 側には標準入出力のフラッシュメソッドがないので、ハックを使うしかありません。Python は書き込み後に最新のデータを間に合うように取得できません。}, 500) exports.getMsg = 関数 getMsg(ip, cb) { コールバック.push(cb) child.stdin.write(`${ip}\n`); // 子プロセスの標準入力にデータを書き込みます} Python と Nodejs は stdio を介して通信します。Python は、メモリ常駐と長期操作を実現するために、epoll を介して stdin をリッスンします。 問題
要約するNodejs と Python 間の双方向通信は実現できますが、前述の問題のため、この方法はここでは推奨されません。HTTP または Socket の方がはるかに優れています。 NodejsとPythonの双方向通信の実装コードに関するこの記事はこれで終わりです。NodejsとPythonの双方向通信に関するより関連性の高いコンテンツについては、123WORDPRESS.COMの過去の記事を検索するか、以下の関連記事を引き続き閲覧してください。今後とも123WORDPRESS.COMをよろしくお願いいたします。 以下もご興味があるかもしれません:
|
<<: Docker を使用して nginx で tomcat クラスターを構築する方法 (画像とテキスト付き)
>>: MYSQL トランザクション チュートリアル Yii2.0 マーチャント引き出し機能
序文: Linux システムでの rm は元に戻せません。コマンドの設計自体に問題はありません。問題...
目次1 背景2 コンテナを作成する3 SAパスワードを変更する4 mssql のリンク5. コンテナ...
目次結論は実践分析拡張機能要約する結論は親コンポーネントでカスタム イベントが定義されている場合、子...
mysql ストアド プロシージャの概念:特定のタスク (クエリと更新) を実行できる、データベース...
6つの効果実装コードhtml <h1>CSS 境界遷移</h1> <セ...
ケース1: 最後の提出とプッシュなし次のコマンドを実行します。 git コミット --amend g...
目次1. 実施プロセス2. オブザーバーを表示する3. ウォッチャーを実装する4. コンパイルを実装...
ここでは、PHP、JSP、または .NET 環境については説明しません。アーキテクチャの観点から問題...
MYSQL でよく使用されるクエリ コマンド: mysql> select version()...
google.htmlインターフェースは図の通りですコードは図のとおりです: (比較的シンプルで、入...
目次序文jQuery 以外の場合は何を使うのでしょうか? DOMとイベントAJAX リクエスト要約す...
この記事では、MySQL の ROUND 関数を使用した丸め操作の落とし穴を例を使って説明します。ご...
面接官から「NodeJS で複数のプロセスを開始する方法を教えてください」と尋ねられることがあります...
<br />HTML 言語では、タグを使用してテーブルにタイトルを自動的に追加できます。...
Nginx は、リバース プロキシ機能を使用して負荷分散を実装できるほか、フォワード プロキシ機能を...