One platform for real-time insights

// Java custom response example
import com.fractalworks.streams.core.data.streams.StreamEvent;;
import com.fractalworks.streams.core.exceptions.TranslationException;;
import com.fractalworks.streams.sdk.codec.CustomTransformer;;
import com.fractalworks.streams.sdk.exceptions.StreamsException;;

public class ActivationTransformer implements CustomTransformer {
  @Override
  public String transform(StreamEvent event) throws TranslationException{
        // Convert event result in to a activation record
        String activationEvt = null;
        try {

          // Apply custom transformation logic
          ActivationEvent activationEvt = ActivationEvent.create(streamEvent.getEventTime(),
                (Integer)streamEvent.getValue("sensorId"),
                (Integer)streamEvent.getValue("valve_signal"));
              
          jsonActivationEvt = objectMapper.writeValueAsString(activationEvt);
        } catch(JsonProcessingException e){
              throw new TranslationException("Failed to translate ActivationEvent.",e);
        }
        return jsonActivationEvt;
    }
}

# Python real-time control logic
def turn_on_or_off(event):
    # Get sensor readings
    temperature = event.get_value('temperature_EMA')
    humidity = event.get_value('mqValue_EMA')
    co2 = event.get_value('co2_EMA')
    mq_value = event.get_value('humidity_EMA')

    # Determine control state
    status = -1

    # Test if control units to be switched OFF
    if temperature < 25 and (mq_value < 2000 or co2 < 1000) \
       and humidity > 85:
        status = 0

    # Test if control units to be switched ON
    elif temperature >= 25 or mq_value >= 2000 or \
         co2 >= 1000 or humidity < 86:
        status = 1

    # Return status result
    return status

// JavaScript real-time control logic
export function turnONorOFF(event) {
    // Get sensor readings
    const temperature = event.getValue('temperature_EMA');
    const humidity = event.getValue('mqValue_EMA');
    const co2 = event.getValue('co2_EMA');
    const mqValue = event.getValue('humidity_EMA');

    // Determine control state
    let status = -1;

    // Test if control units to be switched OFF
    if (temperature_EMA < 25 && (mqValue < 2000 || co2_EMA < 1000)
      && humidity_EMA > 85) {
        status = 0;
    }

    // Test if control units to be switched ON
    else if (temperature_EMA >= 25 || mqValue >= 2000 ||
              co2_EMA >= 1000 || humidity_EMA < 86) {
        status = 1;
    }

    // Return status result
    return status;
}