spacecruft
/
lofarimaging
1
0
Fork 0
Code Issues Releases Activity

Fix memory leak in OPCUA scraper

pull/2/head
Tammo Jan Dijkema 2020-04-01 08:45:09 +02:00
parent 48624bbaad
commit ffced0cb4d
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
collect_from_opcua.py
View File

@ -5,6 +5,7 @@ from lofarimaging.opc_interface import download_xst
from lofarimaging import make_xst_plots
import threading
import sys
import matplotlib.pyplot as plt
integration_time_s = 5
@ -12,16 +13,16 @@ def download_and_image(station_name, subband):
port = 50000 + int(station_name[2:])
obstime, visibilities, rcu_mode = download_xst(subband, integration_time_s, port=port)
if rcu_mode in (1, 2, 3, 4):
sky_fig, ground_fig, leaflet_map = make_xst_plots(visibilities, station_name, obstime, subband, rcu_mode, hdf5_filename=f"results/results.h5",
extent=[-300, 300, -300, 300])
sky_fig, ground_fig, leaflet_map = make_xst_plots(visibilities, station_name, obstime, subband, rcu_mode, hdf5_filename=f"results/results.h5", extent=[-300, 300, -300, 300], outputpath='/Volumes/home/RFI')
plt.close('all')
else:
print("Unsupported rcu mode:", rcu_mode)
if __name__ == "__main__":
while True:
for subband in (250, 350, 375):
for station_name in ("RS210", "RS208", "CS103"):
for station_name in ("RS210", "RS208", "CS103"):
for subband in (150, 250, 350, 375, 400, 425):
thread = threading.Thread(target=download_and_image, args=(station_name, subband))
thread.start()
time.sleep(60)
time.sleep(30)