Send message using TCP protocol to a external server
Hello everyone I'm currently working on migrating from On-Premise to Fabric a process that sends a message through TCP connection to a external server. In the On-Premise version of the server it uses a bash command to send it: echo {message_string} | timeout {timeout_int} ncat -v {domain_string} {port_int} So now I ask the question ¿How can I do this in Microsoft Fabric? Currently, I am generating the text for the message using a pipeline, as shown in the image below: I tried sending the message using a Notebook with the following code: mensaje_tcp = "Hello Server!" ## The message would be the variable introduced in the notebook host = "tcpbin.com" ## public tcp server for testing port = 4242 import socket def send_message_tcp(message, host, port) : with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s: # Configure timeout s.settimeout(60) # 60 segundos de timeout # Connect to the server s.connect((host, port)) try: # Send the message s.sendall(message.encode()) # Receive the response response = s.recv(1024) # Adjust buffer size as needed print("Response:", response.decode()) if response: print("Mensaje enviado correctamente.") else: print("Error: No se recibió respuesta del servidor.") raise Exception(f"ERROR: No se recibió respuesta del servidor.") except socket.timeout: print("Error: tiempo de espera agotado. No se recibió respuesta del servidor.") raise Exception(f"ERROR: Tiempo de espera agotado. No se recibió respuesta del servidor.") # Envío TCP send_message_tcp(mensaje_tcp, host, port) Initially, this worked, but it has since stopped working, and I'm not sure why. I was told that an event stream could be used for doing this, but i need some guidance on how. Thanks !
