@@ 525-540 (lines=16) @@ | ||
522 | event_res.append(events.Event.from_event_fields(evfilter.SelectClauses, res.EventFields)) |
|
523 | return event_res |
|
524 | ||
525 | def history_read_events(self, details): |
|
526 | """ |
|
527 | Read event history of a node, low-level function |
|
528 | result code from server is checked and an exception is raised in case of error |
|
529 | """ |
|
530 | valueid = ua.HistoryReadValueId() |
|
531 | valueid.NodeId = self.nodeid |
|
532 | valueid.IndexRange = '' |
|
533 | ||
534 | params = ua.HistoryReadParameters() |
|
535 | params.HistoryReadDetails = details |
|
536 | params.TimestampsToReturn = ua.TimestampsToReturn.Both |
|
537 | params.ReleaseContinuationPoints = False |
|
538 | params.NodesToRead.append(valueid) |
|
539 | result = self.server.history_read(params)[0] |
|
540 | return result |
|
541 | ||
542 | def delete(self, delete_references=True): |
|
543 | """ |
|
@@ 475-490 (lines=16) @@ | ||
472 | result = self.history_read(details) |
|
473 | return result.HistoryData.DataValues |
|
474 | ||
475 | def history_read(self, details): |
|
476 | """ |
|
477 | Read raw history of a node, low-level function |
|
478 | result code from server is checked and an exception is raised in case of error |
|
479 | """ |
|
480 | valueid = ua.HistoryReadValueId() |
|
481 | valueid.NodeId = self.nodeid |
|
482 | valueid.IndexRange = '' |
|
483 | ||
484 | params = ua.HistoryReadParameters() |
|
485 | params.HistoryReadDetails = details |
|
486 | params.TimestampsToReturn = ua.TimestampsToReturn.Both |
|
487 | params.ReleaseContinuationPoints = False |
|
488 | params.NodesToRead.append(valueid) |
|
489 | result = self.server.history_read(params)[0] |
|
490 | return result |
|
491 | ||
492 | def read_event_history(self, starttime=None, endtime=None, numvalues=0, evtypes=ua.ObjectIds.BaseEventType): |
|
493 | """ |