643450_ja-JP

liliconcom

HTTP リクエストをリッスンしてコールバック関数を起動するにはどうすればよいですか?

ソケットの例を読んでいましたが、JMP にできるのはリクエストの受信を確認することだけで、リクエストのペイロードやメッセージを取得できません。ノンブロッキング通信を実現するソケットやスケジューラよりも優れた方法はありますか?

すべてはWindows上にあります。

スクリプトインデックス: ソケット

JSL を使用して API からデータを取得するための詳細なガイダンス

 

JMP、R、および Python スクリプトからメッセージを取得してログに記録するためのソケット通信

 

 

これも理解できません: ((blobdata == Char To Blob( "" )) & (Left(r[2], 11) == "WOUULDBLOCK:" ))

r[2]とは何ですか? これらの値は、さまざまなものにインデックスを付け続けますか? Python では次のようなことを言うことを期待しています:

r = リクエスト
my_data_dict = r 。アップデート（{ 'last_jmp_data' :pd.DataFrame(request.json)})

これはPythonでデータを取得するために機能しますが、JMPに戻そうとすると、出力されるのはヘッダーだけであり、送信したJSONデータにアクセスできません。 私のデータはどこかにあると思いますr[#]項目?

データを受信できるノンブロッキングなものを作成しようとしています。現在、スケジューラーを使用してハッキングなソリューションを使用してワークフローを作成しており、実際には機能しますが、不格好です。

 

スケジューラーを使用してこの関数のスケジュールを維持します。これがフラスコサーバーにヒットし、データをJSONとして受信し、メインテーブルを更新します。更新によりJMPはすべてのフィルターを削除するため、それを文字列に記録してから、それを再適用します。彼らがしていたことを失うことはありません。

私が望んでいるのは、JavaScript からリクエストを送信し、それを JMP で取得できるようにすることです。
これは私の JavaScript 関数です。応答は必要ありません。JMP に送信するだけです。 以前は、別の JavaScript 回避策を使用して JSON ファイルをダウンロードに書き込み、スケジューラー ループを使用して、テーブルを更新する特定の JSON ファイルのユーザー ダウンロード フォルダーを監視していました。

 

このアプリケーションは、ユーザーの PC 上でローカルに実行されるシングル ユーザー アプリであり、外部リソースと通信しません。ブラウザーで GUI と特定のデータのやり取りを行う必要があるだけですが、そのデータを JMP に戻したいと考えています。私のキメラ JMP/HTML/JS/CS S アプリケーション。

ブラウザからPythonサーバーにデータを送信するために使用するJavaScriptコード

 

            var xhr = new XMLHttpRequest();
                xhr.open("POST", 'http://localhost:8088/passdata', true);
                xhr.setRequestHeader('Content-Type', 'application/json');
                xhr.send([my_json_data]);

 

 

 

 

Jmp スケジューラ ループ

//scheduled loop to ping python local server and see if it's time to update:
get_remote_update = Function({},
 s = Schedule(.25,
  //show("remote update fn");
  //check_downloads_folder(); // old routine that was watching download folder
  check_downloads_over_ip();
  get_remote_update(); //loops by scheduling the event again
 );

Python サーバーへの jmp 呼び出しは JSON データを受信し、必要に応じて更新します。

 

//****************************************************************
//check_downloads_OVER_IP(); 
//****************************************************************
// EXPLORE THIS dt = Open( Char To Blob( request << Send() ), "JSON" );
// see if we can just get the response back into a table without creating it with the weird JMP thing
check_downloads_over_ip = Function({},
 request = New HTTP Request(
  URL("localhost:8088/get_update"),
  Method("Post"),
  Timeout( .5 ),
 );
 data=request << Send;
 if((data != "No Update" > 0) & ( isempty(data) != 1 ),
  obj = JSON:Parse( data );
  dt = JSON:Make Table(obj);
  dt << show window(0);
  
  temp_dtf = CHAR(dtf <<GET script=""></GET>

 

 

ソケットスクリプトがわかりません

 

 

Names default to here( 1 );

//Table to hold received data
dtLog = New Table( "Log",
 New Column( "Time", Numeric, "Continuous", Format( "m/d/y h:m:s", 23, 0 ),
  Input Format( "m/d/y h:m:s", 0 ) ),
 New Column( "Client", Character, "Nominal" ),
 New Column( "Message", Character, "Nominal" )
);

//Wait for and get data from remote machine
receivedata = Function( {c, waittime = 1, waitcount = 10},
 
 //Varaible to store data received from remote machine
 blobdata = Char To Blob( "" );
 
 //Make socket is connected
 r = c << GetPeerName();
 
 //While receiving data or waiting to receive data
 i = 0;
 While( 
  ( 
   (r[2] == "ok") | 
   ((blobdata == Char To Blob( "" )) & (Left(r[2], 11) == "WOULDBLOCK:" ))
  ) & 
  (i < waitcount),
  
  i++;
  
  //Get data
  r = c << recv( 100000 );
  //If no data is received yet, wait 
  If(Left(r[2], 11) == "WOULDBLOCK:", Wait( waittime ) );
  
  //Write whatever is received to the log
  show("writing to log now");
  Write( Blob to Char( r[3] ) );
  show("Done writing to log now");
  //join data to whatever is already received
  blobdata = blobdata || r[3];
 );
 
 return( blobdata );
);

//Get log info from remote machine, store it in a data table
processlogconnection = function( {c},

 //New row in log table
 dtLog << Add Rows( 1 );
 rowout = N Rows( dtLog );
 Column( dtLog, "Time" )[rowout] = Today();
 
 //Get computer name of remote machine
 r = c << GetPeerName();
 Column( dtLog, "Client" )[rowout] = r[3];
 
 //Get message from the remote machine
 Column( dtLog, "Message" )[rowout] = Blob to Char( receivedata( c ) );
 
 //Close the connection
 c << Close;
);

//Function to accept conections from remote machine, calls another
//function to handle communication with that machine
callbackfn = function( {x}, 
 //Call another function with the connection returned from the Accept message
 If( x[2] == "ok", processlogconnection( x[4] ) );
);

//Create a socket
con = Socket();

//Use a specific port on this computer
con << Bind( "localhost", "8081" );

//Tell this socket to be ready for other sockets to connect to it
Write( "\!nlistening on ", (con << getSockName)[3]);
con << Listen();

//Verify that the connection is active
con << getsockname;

//When something connects to this socket, call a function to handle
//the connection.  Accept connections for the next 5 minutes.
con << Accept(callbackfn, 30000);

//Now messages can be sent to this connection.

//When all done, close the connection
//con << close();

 

 

自動化とスクリプト作成結果の共有と伝達ウィンドウズ