@@ 549-564 (lines=16) @@ | ||
546 | event_res.append(events.Event.from_event_fields(evfilter.SelectClauses, res.EventFields)) |
|
547 | return event_res |
|
548 | ||
549 | def history_read_events(self, details): |
|
550 | """ |
|
551 | Read event history of a node, low-level function |
|
552 | result code from server is checked and an exception is raised in case of error |
|
553 | """ |
|
554 | valueid = ua.HistoryReadValueId() |
|
555 | valueid.NodeId = self.nodeid |
|
556 | valueid.IndexRange = '' |
|
557 | ||
558 | params = ua.HistoryReadParameters() |
|
559 | params.HistoryReadDetails = details |
|
560 | params.TimestampsToReturn = ua.TimestampsToReturn.Both |
|
561 | params.ReleaseContinuationPoints = False |
|
562 | params.NodesToRead.append(valueid) |
|
563 | result = self.server.history_read(params)[0] |
|
564 | return result |
|
565 | ||
566 | def delete(self, delete_references=True, recursive=False): |
|
567 | """ |
|
@@ 499-514 (lines=16) @@ | ||
496 | result = self.history_read(details) |
|
497 | return result.HistoryData.DataValues |
|
498 | ||
499 | def history_read(self, details): |
|
500 | """ |
|
501 | Read raw history of a node, low-level function |
|
502 | result code from server is checked and an exception is raised in case of error |
|
503 | """ |
|
504 | valueid = ua.HistoryReadValueId() |
|
505 | valueid.NodeId = self.nodeid |
|
506 | valueid.IndexRange = '' |
|
507 | ||
508 | params = ua.HistoryReadParameters() |
|
509 | params.HistoryReadDetails = details |
|
510 | params.TimestampsToReturn = ua.TimestampsToReturn.Both |
|
511 | params.ReleaseContinuationPoints = False |
|
512 | params.NodesToRead.append(valueid) |
|
513 | result = self.server.history_read(params)[0] |
|
514 | return result |
|
515 | ||
516 | def read_event_history(self, starttime=None, endtime=None, numvalues=0, evtypes=ua.ObjectIds.BaseEventType): |
|
517 | """ |