@@ 497-512 (lines=16) @@ | ||
494 | event_res.append(events.Event.from_event_fields(evfilter.SelectClauses, res.EventFields)) |
|
495 | return event_res |
|
496 | ||
497 | def history_read_events(self, details): |
|
498 | """ |
|
499 | Read event history of a node, low-level function |
|
500 | result code from server is checked and an exception is raised in case of error |
|
501 | """ |
|
502 | valueid = ua.HistoryReadValueId() |
|
503 | valueid.NodeId = self.nodeid |
|
504 | valueid.IndexRange = '' |
|
505 | ||
506 | params = ua.HistoryReadParameters() |
|
507 | params.HistoryReadDetails = details |
|
508 | params.TimestampsToReturn = ua.TimestampsToReturn.Both |
|
509 | params.ReleaseContinuationPoints = False |
|
510 | params.NodesToRead.append(valueid) |
|
511 | result = self.server.history_read(params)[0] |
|
512 | return result |
|
513 | ||
514 | def delete(self, delete_references=True): |
|
515 | """ |
|
@@ 447-462 (lines=16) @@ | ||
444 | result = self.history_read(details) |
|
445 | return result.HistoryData.DataValues |
|
446 | ||
447 | def history_read(self, details): |
|
448 | """ |
|
449 | Read raw history of a node, low-level function |
|
450 | result code from server is checked and an exception is raised in case of error |
|
451 | """ |
|
452 | valueid = ua.HistoryReadValueId() |
|
453 | valueid.NodeId = self.nodeid |
|
454 | valueid.IndexRange = '' |
|
455 | ||
456 | params = ua.HistoryReadParameters() |
|
457 | params.HistoryReadDetails = details |
|
458 | params.TimestampsToReturn = ua.TimestampsToReturn.Both |
|
459 | params.ReleaseContinuationPoints = False |
|
460 | params.NodesToRead.append(valueid) |
|
461 | result = self.server.history_read(params)[0] |
|
462 | return result |
|
463 | ||
464 | def read_event_history(self, starttime=None, endtime=None, numvalues=0, evtypes=ua.ObjectIds.BaseEventType): |
|
465 | """ |