Forum Discussion

Anonymous's avatar
Anonymous
Not applicable
2 years ago

Send data through TCP 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 ...
Need Help
v-cboorla-msft's avatar
v-cboorla-msft
Microsoft Employee
2 years ago

Hi Anonymous 

 

I have received an update from the internal team as follows:

"We cannot just push to an unauthenticated TCP port when using Fabric". But one option if you just need to sent some text to an endpoint would be to use an event stream. You can use a custom app endpoint. You can treat this like an eventhub, AQMP or Kafka endpoint.

Please refer for more details: Add a custom app source to an eventstream - Microsoft Fabric | Microsoft Learn

 

I hope this information helps.

 

Thank you.

Anonymous's avatar
Anonymous
Not applicable
2 years ago

Hello,

Thank you for your response. However, I need more detailed information on how to use an event stream for sending a text message.

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.

Could you please provide guidance on how to integrate this process with a stream? I assume the pipeline would need to send the generated text to the stream, and then maybe an Azure Function would consume the stream and forward the text to the TCP destination.

f that's the case, can the Azure Function send data to an unauthenticated TCP server?

Thank you for your assistance.