-
Notifications
You must be signed in to change notification settings - Fork 4
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #377 from lnls-sirius/PR-add-ps-ioc-fbp-pvs
Pr add ps ioc fbp pvs
- Loading branch information
Showing
7 changed files
with
224 additions
and
107 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1 +1 @@ | ||
| 1.15.0 | ||
| 1.16.0 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,90 @@ | ||
| """.""" | ||
|
|
||
| from .client import ClientArchiver as _ClientArchiver | ||
|
|
||
|
|
||
| class PVArch: | ||
| """PVArch.""" | ||
|
|
||
| def __init__(self, pvname, client_archiver=None): | ||
| """.""" | ||
| self.pvname = pvname | ||
| self.is_scalar = None | ||
| self.nelms = None | ||
| self.units = None | ||
| self.is_paused = None | ||
| self.host_name = None | ||
| self.connected = None | ||
| self.avg_bytes_per_event = None | ||
| self.estimated_storage_rate_kb_hour = None | ||
| self.estimated_storage_rate_mb_day = None | ||
| self.estimated_storage_rate_gb_year = None | ||
|
|
||
| self.connector = client_archiver | ||
|
|
||
| def login(self, **kwargs): | ||
| """.""" | ||
| self.connect() | ||
| self.connector.login(**kwargs) | ||
|
|
||
| def connect(self): | ||
| """.""" | ||
| if self.connector is None: | ||
| self.connector = _ClientArchiver() | ||
|
|
||
| def update(self): | ||
| """.""" | ||
| self.connect() | ||
| data = self.connector.getPVDetails(self.pvname) | ||
| for datum in data: | ||
| # print(datum) | ||
| field, value = datum['name'], datum['value'] | ||
| if field == 'Is this a scalar:': | ||
| self.is_scalar = (value.lower() == 'yes') | ||
| elif field == 'Number of elements:': | ||
| self.nelms = int(value) | ||
| elif field == 'Units:': | ||
| self.units = value | ||
| elif field == 'Is this PV paused:': | ||
| self.is_paused = (value.lower() == 'yes') | ||
| elif field == 'Host name': | ||
| self.host_name = value | ||
| elif field == 'Host name': | ||
| self.host_name = value | ||
| elif field == 'Is this PV currently connected?': | ||
| self.connected = (value.lower() == 'yes') | ||
| elif field == 'Average bytes per event': | ||
| self.avg_bytes_per_event = float(value) | ||
| elif field == 'Estimated storage rate (KB/hour)': | ||
| self.estimated_storage_rate_kb_hour = float(value) | ||
| elif field == 'Estimated storage rate (MB/day)': | ||
| self.estimated_storage_rate_mb_day = float(value) | ||
| elif field == 'Estimated storage rate (GB/year)': | ||
| self.estimated_storage_rate_gb_year = float(value) | ||
|
|
||
| def getData(self, timestamp_start, timestamp_stop): | ||
| """.""" | ||
| self.connect() | ||
| timestamp, value, status, severity = \ | ||
| self.connector.getData(self.pvname, timestamp_start, timestamp_stop) | ||
| return timestamp, value, status, severity | ||
|
|
||
| def __str__(self): | ||
| """.""" | ||
| rst = '' | ||
| rst += '{:<30s}: {:}\n'.format('pvname', self.pvname) | ||
| rst += '{:<30s}: {:}\n'.format('is_scalar', self.is_scalar) | ||
| rst += '{:<30s}: {:}\n'.format('nelms', self.nelms) | ||
| rst += '{:<30s}: {:}\n'.format('units', self.units) | ||
| rst += '{:<30s}: {:}\n'.format('is_paused', self.is_paused) | ||
| rst += '{:<30s}: {:}\n'.format('host_name', self.host_name) | ||
| rst += '{:<30s}: {:}\n'.format('connected', self.connected) | ||
| rst += '{:<30s}: {:}\n'.format( | ||
| 'avg_bytes_per_event', self.avg_bytes_per_event) | ||
| rst += '{:<30s}: {:}\n'.format( | ||
| 'estimated_storage_rate_kb_hour', self.estimated_storage_rate_kb_hour) | ||
| rst += '{:<30s}: {:}\n'.format( | ||
| 'estimated_storage_rate_mb_day', self.estimated_storage_rate_mb_day) | ||
| rst += '{:<30s}: {:}\n'.format( | ||
| 'estimated_storage_rate_gb_year', self.estimated_storage_rate_gb_year) | ||
| return rst |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.