Send message using TCP protocol to a external server

[Anonymous]

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 !

[Anonymous · Accepted solution]

Hi @Anonymous ,

1.Start by setting up an eventstream item. This will be your central configuration for capturing and routing messages.

2.Since you're targeting an external server over TCP, you'll need a custom application that can act as a bridge. This app will consume messages from the eventstream and forward them to your external server using TCP. The custom app can be hosted in a container or a VM within Azure, ensuring it has network access to your target server.

3.Configure the Eventstream to Use Your Custom App as a Destination.

Please refer: Add custom app source to an eventstream - Microsoft Fabric | Microsoft Learn

Best Regards,

Neeko Tang

If this post  helps, then please consider Accept it as the solution  to help the other members find it more quickly.