NinjaTrader WebSocket client

October 27th, 2023, 05:17 PM

Here's a WebSocket client for NinjaTrader 8 to facilitate communication between programming languages that support the WebSocket protocol. I've attached the indicator and a Python example .

I created this indicator to integrate with Ninjatrader and leverage AI tools such as Langchain, Microsoft Semantic Kernel, Autogen, and more.

If allowed, here's the source code
https://github.com/mattalford/ninja-socket

Code

git clone https://github.com/mattalford/ninja-socket.git
cd python_example
pip install -r requirements.txt
uvicorn main:app --reload

Code

NinjaScript Output:
Data: Sent data - Hello Word!

October 28th, 2023, 03:17 PM

pixel

Here's a WebSocket client for NinjaTrader 8 to facilitate communication between programming languages that support the WebSocket protocol. I've attached the indicator and a Python example .

I created this indicator to integrate with Ninjatrader and leverage AI tools such as Langchain, Microsoft Semantic Kernel, Autogen, and more.

If allowed, here's the source code
https://github.com/mattalford/ninja-socket

Code

git clone https://github.com/mattalford/ninja-socket.git
cd python_example
pip install -r requirements.txt
uvicorn main:app --reload

Code

NinjaScript Output:
Data: Sent data - Hello Word!

How this should be implemented into the NT8 ?

October 28th, 2023, 04:53 PM

rolexrsp

How this should be implemented into the NT8 ?

This is for developers and individuals interested in bi-directional data communication using WebSocket in their preferred programming language. You can utilize the NinjaSocket source code in your own indicators or strategies. For instance, if you wish to send OHLC data from NinjaTrader to Python for analysis

Here's a short code snippet
NinjaScript

Code

string data = "";  
  
for (int i = 0; i < Bars.Count; i++)  
{      double open = Bars.GetOpen(i);  
    double high = Bars.GetHigh(i);  
    double low = Bars.GetLow(i);  
    double close = Bars.GetClose(i);  
    double volume = Bars.GetVolume(i);  
    DateTime time = Bars.GetTime(i);  
  
    data += string.Format("{0}|{1}|{2}|{3}|{4}|{5};", open, high, low, close, volume, time);  }

// Send the data
SendDataAsync(data);

Python

Code

data = await websocket.receive_text()
bars = data.decode('utf-8').split(';')  
for bar in bars:  open, high, low, close, volume, time = bar.split('|')  
open, high, low, close, volume = map(float, [open, high, low, close, volume])  
time = datetime.datetime.strptime(time, "%m/%d/%Y %H:%M:%S")
print(f"Open: {open}, High: {high}, Low: {low}, Close: {close}, Volume: {volume}, Time: {time}")

NinjaTrader WebSocket client

Discussion in NinjaTrader

NinjaTrader WebSocket client