Add CSV-driven OPC UA server with Docker

Add an async OPC UA server (csv_opcua_server.py) that reads data.csv and publishes each CSV row as OPC UA variables at a configurable interval, plus a simple HTTP health endpoint on port 8080. Add a Dockerfile to build the image (python:3.11-slim, installs gcc for binary deps), copies requirements and app files, and exposes ports 4840 and 8080. Include a sample data.csv and a requirements.txt listing dependencies. Note: requirements.txt contains a typo ('requestsc' should be 'requests').

Dockerfile

@@ -0,0 +1,26 @@
+# Use lightweight Python image
+FROM python:3.11-slim
+
+# Set working directory
+WORKDIR /app
+
+# Install system dependencies (optional but safe for pandas)
+RUN apt-get update && apt-get install -y \
+    gcc \
+    && rm -rf /var/lib/apt/lists/*
+
+# Copy only requirements first (better layer caching)
+COPY requirements.txt .
+
+# Install Python dependencies
+RUN pip install --no-cache-dir -r requirements.txt
+
+# Copy application files
+COPY . .
+
+# Expose ports
+EXPOSE 4840
+EXPOSE 8080
+
+# Run the app
+CMD ["python", "csv_opcua_server.py"]

csv_opcua_server.py

@@ -0,0 +1,114 @@
+import asyncio
+import threading
+from http.server import HTTPServer, BaseHTTPRequestHandler
+
+import pandas as pd
+import requests
+from asyncua import Server, ua
+
+# =========================
+# CONFIGURATION
+# =========================
+BIND_IP = "0.0.0.0"
+OPCUA_PORT = 4840
+HTTP_PORT = 8080
+CSV_FILE = "data.csv"
+ROW_INTERVAL = 2  # seconds
+
+# =========================
+# PUBLIC IP DETECTION
+# =========================
+def get_public_ip():
+    try:
+        return requests.get("https://ipinfo.io/ip", timeout=5).text.strip()
+    except Exception:
+        return "127.0.0.1"
+
+PUBLIC_IP = get_public_ip()
+
+ENDPOINT = f"opc.tcp://{BIND_IP}:{OPCUA_PORT}/csv-opcua-server/"
+PUBLIC_ENDPOINT = f"opc.tcp://{PUBLIC_IP}:{OPCUA_PORT}/csv-opcua-server/"
+
+# =========================
+# SIMPLE HTTP SERVER
+# =========================
+class HealthHandler(BaseHTTPRequestHandler):
+    def do_GET(self):
+        self.send_response(200)
+        self.send_header("Content-type", "text/plain")
+        self.end_headers()
+        self.wfile.write(b"OK - Server is reachable via browser\n")
+
+    def log_message(self, format, *args):
+        return
+
+def start_http_server():
+    httpd = HTTPServer((BIND_IP, HTTP_PORT), HealthHandler)
+    print(f"HTTP server running on http://{PUBLIC_IP}:{HTTP_PORT}")
+    httpd.serve_forever()
+
+# =========================
+# MAIN ASYNC OPC UA SERVER
+# =========================
+async def main():
+    # Load CSV
+    df = pd.read_csv(CSV_FILE)
+    if df.empty:
+        raise ValueError("CSV file is empty")
+
+    # Create OPC UA server
+    server = Server()
+    await server.init()
+    server.set_endpoint(ENDPOINT)
+    server.set_server_name("Public CSV OPC UA Async Server")
+
+    uri = "http://example.org/public-csv-opcua"
+    idx = await server.register_namespace(uri)
+
+    objects = server.nodes.objects
+    csv_obj = await objects.add_object(idx, "CSV_Data")
+
+    # Create variables
+    variables = {}
+    for col in df.columns:
+        var = await csv_obj.add_variable(
+            idx,
+            col,
+            float(df[col].iloc[0]),
+            ua.VariantType.Double,
+        )
+        await var.set_writable()
+        variables[col] = var
+
+    print("====================================")
+    print(" OPC UA SERVER RUNNING (ASYNC)")
+    print(f" Internal bind : {ENDPOINT}")
+    print(f" Public access : {PUBLIC_ENDPOINT}")
+    print(f" Publishing 1 row every {ROW_INTERVAL} seconds")
+    print("====================================")
+
+    row_index = 0
+    row_count = len(df)
+
+    async with server:
+        while True:
+            row = df.iloc[row_index]
+            print(f"Publishing row {row_index + 1}/{row_count}")
+
+            for col, var in variables.items():
+                value = float(row[col])
+                await var.write_value(value)
+                print(f"  {col} = {value}")
+
+            row_index = (row_index + 1) % row_count
+            await asyncio.sleep(ROW_INTERVAL)
+
+# =========================
+# START EVERYTHING
+# =========================
+if __name__ == "__main__":
+    # Start HTTP server in background thread
+    threading.Thread(target=start_http_server, daemon=True).start()
+
+    # Start async OPC UA server
+    asyncio.run(main())

data.csv

@@ -0,0 +1,6 @@
+rpm,xtilt,db
+750.2,0.12,22.0
+751.2,0.25,23.0
+752.2,0.22,22.1
+751.5,0.15,22.5
+750.1,0.14,22.1

requirements.txt

@@ -0,0 +1,4 @@
+asyncua
+pandas
+requestsc
+