643450_zh-CN

liliconcom

如何监听 HTTP 请求然后触发回调函数？

我一直在阅读套接字示例，但我只能让 JMP 确认收到请求，但我无法获取请求的有效负载或消息。有没有比套接字或调度程序更好的方法来实现非阻塞通信？

一切都在窗户上。

脚本索引：套接字

使用 JSL 从 API 获取数据的详细指南

 

用于从 JMP、R 和 Python 脚本获取和记录消息的套接字通信

 

 

我也不明白这个： ((blobdata == Char To Blob( "" )) & (Left(r[2], 11) == "WOULDBLOCK:" ))

r[2] 是什么？ 这些东西的价值不断索引到不同的东西？ 在 python 中，我会期待这样说：

r = 请求
我的数据字典 = r 。更新（{ 'last_jmp_data' :pd.DataFrame(request.json)})

这在 python 中有效以检索我的数据，但是当我尝试传回 JMP 时，唯一打印的是标头，我无法访问我发送的 JSON 数据。 我假设我的数据在一些r[#] 项目？

我正在尝试制作一些可以接收数据的非阻塞的东西，现在我正在使用一个带有调度程序的 hacky 解决方案来创建工作流并且它确实有效，但它很笨重。

 

我使用调度程序来安排此功能，这会触发我的烧瓶服务器，以 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]);

 

 

 

 

跳转调度程序循环

//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();

 

 

自动化和脚本共享和交流结果视窗