fledge-iot / fledge-service-dispatcher

Dispatcher service is responsible for dispatching control messages between Fledge services.
0 stars 0 forks source link

Control pipeline is called when commands are sent from a plugin other than the specified source. #42

Open jude-adam opened 10 months ago

jude-adam commented 10 months ago

Pipeline is configured to be used when sending commands from the plugin "iec104north", but is being called when sending commands from "scheduler-north" plugin.

Nov 6 14:57:29 GRIDCORE-002 Fledge dispatcher[92715]: ERROR: Failed to send set point operation to service south61, 400 Bad Request, { "status" : "failed to parse operation payload" }

Nov 6 14:57:29 GRIDCORE-002 Fledge south61[92723]: DEBUG: This service 'south61' has AuthenticatedCaller flag set 0 caller service is scheduler-north, type Northbound

Nov 6 14:57:29 GRIDCORE-002 Fledge dispatcher[92715]: INFO: Control filter pipeline 104pivotcontrol removed control request

Nov 6 14:57:29 GRIDCORE-002 Fledge dispatcher[92715]: DEBUG: iec104_pivot_filter - IEC104PivotFilter::ingest - converted Reading: ({"asset_code":"IEC104Command","user_ts":"2023-11-06 14:57:29.033489+00:00","ts":"2023-11-06 14:57:29.033489+00:00","reading":{}})

Nov 6 14:57:29 GRIDCORE-002 Fledge dispatcher[92715]: ERROR: iec104_pivot_filter - IEC104PivotFilter::ingest - Failed to convert Pivot operation object

Nov 6 14:57:29 GRIDCORE-002 Fledge dispatcher[92715]: ERROR: iec104_pivot_filter - IEC104PivotFilter::convertReadingToIEC104OperationObject - Failed to convert pivot operation object: No pivot object

Nov 6 14:57:29 GRIDCORE-002 Fledge dispatcher[92715]: DEBUG: iec104_pivot_filter - IEC104PivotFilter::ingest - original Reading: ({"asset_code":"PivotCommand","user_ts":"2023-11-06 14:57:29.033489+00:00","ts":"2023-11-06 14:57:29.033489+00:00","reading":{"PIVOTTC":"{\"GTIC\":{\"ComingFrom\":\"iec61850\", \"ApcTyp\":{\"q\":{\"test\":0}, \"t\":{\"SecondSinceEpoch\":1699282649, \"FractionOfSecond\":520093}, \"ctlVal\":6.0}, \"Identifier\":\"TS1\"}}"}})

Nov 6 14:57:29 GRIDCORE-002 Fledge dispatcher[92715]: DEBUG: Filtering control request for piepline '104pivotcontrol', {"asset_code":"PivotCommand","user_ts":"2023-11-06 14:57:29.033489+00:00","ts":"2023-11-06 14:57:29.033489+00:00","reading":{"PIVOTTC":"{\"GTIC\":{\"ComingFrom\":\"iec61850\", \"ApcTyp\":{\"q\":{\"test\":0}, \"t\":{\"SecondSinceEpoch\":1699282649, \"FractionOfSecond\":520093}, \"ctlVal\":6.0}, \"Identifier\":\"TS1\"}}"}}

Nov 6 14:57:29 GRIDCORE-002 Fledge dispatcher[92715]: INFO: Using shared context for control pipeline '104pivotcontrol' from 'Any' to 'Broadcast'

Nov 6 14:57:29 GRIDCORE-002 Fledge dispatcher[92715]: DEBUG: 104pivotcontrol matches pipelines for source Any to destination (ANY) Broadcast

pipelineissue-01

Maybe the configuration is not being done correctly? " Using shared context for control pipeline '104pivotcontrol' from 'Any' to 'Broadcast'" " 104pivotcontrol matches pipelines for source Any to destination (ANY) "

The same happens when changing the execution to "Exclusive"

MarkRiddoch commented 10 months ago

FOGL-8268 created to resolve this

FlorentP42 commented 3 months ago

This issue also happen in the opposite direction: Control pipeline configured between northA and southA will filter messages sent from northA to southB. Still present in Fledge 2.4.0.