47921_es-ES

liliconcom

Comunicación de socket para obtener y registrar mensajes de secuencias de comandos JMP, R y python

A veces es útil recopilar mensajes o datos en una ubicación central desde scripts de ejecución prolongada o scripts que se ejecutan en equipos remotos.Se adjuntan cuatro archivos que demuestran esto:

 

1. Un 'servidor' que recopila mensajes de otras máquinas o procesos y los coloca en una tabla de datos. Ejecute esto en una instancia separada de JMP de cualquier otro script o tabla.
2. Una secuencia de comandos JSL de 'cliente' que envía mensajes al servidor, incruste esto en las secuencias de comandos.
3. Un script R 'cliente' que envía mensajes al servidor
4. Un script de python 'cliente' que envía mensajes al servidor

 

Aquí hay un ejemplo de cómo podría verse esto, los clientes de la derecha pueden estar en diferentes computadoras o copias separadas de JMP en la misma computadora.

El código importante se ve así:

 

Servidor

//Create a socket
con = Socket();

//Use a specific address and port on this computer
con << Bind( "10.0.0.2", "12345" );

//Tell this socket to be ready for other sockets to connect to it
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, 300);

//Now messages can be sent to this connection.

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

 

Donde la función de devolución de llamada se vería así (la función real es más compleja, vea a continuación):

//Simplified function to handle communication with the client, do not use as is
callbackfn = function( {x}, 
 
 If( x[2] == "ok", 
  //Get data
  r = x[4] << recv( 1000 );
  
  //While data was received
  While( r[2] == "ok",
  
   //Write it to the log
   write( Blob to Char( r[3] ) );
   
   //try to get more data
   r = x[4] << recv( 1000 );
  );
 );
 
 //close the connection to the client
 x[4] << Close;
);

Aquí hay una función de devolución de llamada un poco más compleja que maneja el bloqueo (común):

Ver más...

Aquí hay un ejemplo de un código de servidor completo:

 

Ver más...

 

 

Cliente JSL

Names default to here( 1 );

//function to send a message to a waiting connection
SendMessage = Function( {message},

 //Create a socket
 con = Socket();
 
 //Connect to a socket that is already bound to, listening on, and accepting
 //connections on a port.  This is the server IP address, not the client.
 con << Connect( "10.0.0.2", "12345" );
 
 //Send data
 r = con << Send( Char To Blob( message ) );
 
 ///check that the data was sent
 if(r[2] == "ok", result = "sent", result = "fail" );
 
 //close the connection
 con << Close;
 return( result );
);

//send messages
Write( SendMessage( "Hi" ) );

 

Cliente R

sendmessage = function( message ) {
  con <- socketConnection(host="10.0.0.2", port = 12345, blocking=FALSE,
                          server=FALSE, open="r+")
  
  write_resp <- write(message, con)
  close(con)
}

sendmessage("Hi from R")

 

Cliente Python

import socket
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect(("10.0.0.2", 12345))
client_socket.send("Hello from Python")
client_socket.close()
break;

 

Cliente PowerShell

$socket = new-object System.Net.Sockets.TcpClient( "10.0.0.2", 12345)
$stream = $socket.GetStream()
$writer = new-object System.IO.StreamWriter $stream
$writer.WriteLine( "Hello from Powershell`n" )
$writer.Flush()
$writer.Close()

 

Esto pretende ser más una introducción a la comunicación de socket para cualquiera que busque un código de ejemplo que un mecanismo de registro funcional, ¡pero agradezco sus comentarios y sugerencias!

Una introducción a la comunicación de socket y una forma de obtener mensajes de scripts de ejecución prolongada o máquinas remotas.

Desarrollo de aplicaciones analíticasUtilidades