{ "cells": [ { "cell_type": "code", "execution_count": 1, "metadata": {}, "outputs": [], "source": [ "import hkvfewspy as hkv\n", "import pandas as pd" ] }, { "cell_type": "markdown", "metadata": {}, "source": [ "# Set Rest endpoint" ] }, { "cell_type": "code", "execution_count": 2, "metadata": {}, "outputs": [], "source": [ "pi = hkv.Pi(protocol='rest')\n", "url = 'http://localhost:8080/FewsWebServices/rest/fewspiservice/v1/'\n", "pi.setUrl(url=url)" ] }, { "cell_type": "markdown", "metadata": {}, "source": [ "# Get Requests" ] }, { "cell_type": "code", "execution_count": 3, "metadata": {}, "outputs": [ { "data": { "text/html": [ "
\n", "\n", "\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "
f_ruw_ongevalideerd_ADCf_ruw_ongevalideerd_ADVf_ruw_ongevalideerd_ALTf_ruw_ongevalideerd_AQDf_ruw_ongevalideerd_MPPf_ruw_ongevalideerd_STAf_ruw_ongevalideerd_STBf_ruw_gevalideerd_ADCf_ruw_gevalideerd_ADVf_ruw_gevalideerd_ALTf_ruw_gevalideerd_AQDf_ruw_gevalideerd_MPPf_ruw_gevalideerd_STBf_meteof_dms
idf_ruw_ongevalideerd.ADCf_ruw_ongevalideerd.ADVf_ruw_ongevalideerd.ALTf_ruw_ongevalideerd.AQDf_ruw_ongevalideerd.MPPf_ruw_ongevalideerd.STAf_ruw_ongevalideerd.STBf_ruw_gevalideerd.ADCf_ruw_gevalideerd.ADVf_ruw_gevalideerd.ALTf_ruw_gevalideerd.AQDf_ruw_gevalideerd.MPPf_ruw_gevalideerd.STBf_meteof_dms
nameADCADVALTAQDMPPSTASTBADCADVALTAQDMPPSTBKNMI-meteoDMS-data
\n", "
" ], "text/plain": [ " f_ruw_ongevalideerd_ADC f_ruw_ongevalideerd_ADV \\\n", "id f_ruw_ongevalideerd.ADC f_ruw_ongevalideerd.ADV \n", "name ADC ADV \n", "\n", " f_ruw_ongevalideerd_ALT f_ruw_ongevalideerd_AQD \\\n", "id f_ruw_ongevalideerd.ALT f_ruw_ongevalideerd.AQD \n", "name ALT AQD \n", "\n", " f_ruw_ongevalideerd_MPP f_ruw_ongevalideerd_STA \\\n", "id f_ruw_ongevalideerd.MPP f_ruw_ongevalideerd.STA \n", "name MPP STA \n", "\n", " f_ruw_ongevalideerd_STB f_ruw_gevalideerd_ADC f_ruw_gevalideerd_ADV \\\n", "id f_ruw_ongevalideerd.STB f_ruw_gevalideerd.ADC f_ruw_gevalideerd.ADV \n", "name STB ADC ADV \n", "\n", " f_ruw_gevalideerd_ALT f_ruw_gevalideerd_AQD f_ruw_gevalideerd_MPP \\\n", "id f_ruw_gevalideerd.ALT f_ruw_gevalideerd.AQD f_ruw_gevalideerd.MPP \n", "name ALT AQD MPP \n", "\n", " f_ruw_gevalideerd_STB f_meteo f_dms \n", "id f_ruw_gevalideerd.STB f_meteo f_dms \n", "name STB KNMI-meteo DMS-data " ] }, "execution_count": 3, "metadata": {}, "output_type": "execute_result" } ], "source": [ "filters = pi.getFilters()\n", "filters" ] }, { "cell_type": "code", "execution_count": 4, "metadata": {}, "outputs": [ { "data": { "text/html": [ "
\n", "\n", "\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "
FL65FL66FL67FL68FL69FL70FL65_AFL65_BFL65_CFL69_AFL69_BFL69_C
lat52.5726269470387852.6035143734936252.6344035139421352.6794135355980452.6460500355974952.68834846531182652.5751437752840852.575053890933152.5749640063970352.644496099352352.6445769398696352.64469371574405
locationIdFL65FL66FL67FL68FL69FL70FL65_AFL65_BFL65_CFL69_AFL69_BFL69_C
lon5.372822881095735.36405954188739555.4069102842973345.3244803646572355.410565067359155.3282389932245995.3769230218769325.37677552652794165.37662803178059355.4059840212924525.4062500045649575.406589879488774
shortNameFL65 Marker Wadden ZuiderstrandFL66 Marker Wadden NoorderstrandFL67 Markermeer NatuurstrandFL68 Markermeer VooroeverdamFL69 IJsselmeer 2FL70 IJsselmeer 1FL65_A Marker Wadden ZuiderstrandFL65_B Marker Wadden ZuiderstrandFL65_C Marker Wadden ZuiderstrandFL69_A IJsselmeer 2FL69_B IJsselmeer 2FL69_C IJsselmeer 2
x154025.0153432.0156334.0150758.0156581.0151013.0154303.0154293.0154283.0156271.0156289.0156312.0
y509448.0512885.0516322.0521332.0517618.0522326.0509728.0509718.0509708.0517445.0517454.0517467.0
\n", "
" ], "text/plain": [ " FL65 FL66 \\\n", "lat 52.57262694703878 52.60351437349362 \n", "locationId FL65 FL66 \n", "lon 5.37282288109573 5.3640595418873955 \n", "shortName FL65 Marker Wadden Zuiderstrand FL66 Marker Wadden Noorderstrand \n", "x 154025.0 153432.0 \n", "y 509448.0 512885.0 \n", "\n", " FL67 FL68 \\\n", "lat 52.63440351394213 52.67941353559804 \n", "locationId FL67 FL68 \n", "lon 5.406910284297334 5.324480364657235 \n", "shortName FL67 Markermeer Natuurstrand FL68 Markermeer Vooroeverdam \n", "x 156334.0 150758.0 \n", "y 516322.0 521332.0 \n", "\n", " FL69 FL70 \\\n", "lat 52.64605003559749 52.688348465311826 \n", "locationId FL69 FL70 \n", "lon 5.41056506735915 5.328238993224599 \n", "shortName FL69 IJsselmeer 2 FL70 IJsselmeer 1 \n", "x 156581.0 151013.0 \n", "y 517618.0 522326.0 \n", "\n", " FL65_A \\\n", "lat 52.57514377528408 \n", "locationId FL65_A \n", "lon 5.376923021876932 \n", "shortName FL65_A Marker Wadden Zuiderstrand \n", "x 154303.0 \n", "y 509728.0 \n", "\n", " FL65_B \\\n", "lat 52.5750538909331 \n", "locationId FL65_B \n", "lon 5.3767755265279416 \n", "shortName FL65_B Marker Wadden Zuiderstrand \n", "x 154293.0 \n", "y 509718.0 \n", "\n", " FL65_C FL69_A \\\n", "lat 52.57496400639703 52.6444960993523 \n", "locationId FL65_C FL69_A \n", "lon 5.3766280317805935 5.405984021292452 \n", "shortName FL65_C Marker Wadden Zuiderstrand FL69_A IJsselmeer 2 \n", "x 154283.0 156271.0 \n", "y 509708.0 517445.0 \n", "\n", " FL69_B FL69_C \n", "lat 52.64457693986963 52.64469371574405 \n", "locationId FL69_B FL69_C \n", "lon 5.406250004564957 5.406589879488774 \n", "shortName FL69_B IJsselmeer 2 FL69_C IJsselmeer 2 \n", "x 156289.0 156312.0 \n", "y 517454.0 517467.0 " ] }, "execution_count": 4, "metadata": {}, "output_type": "execute_result" } ], "source": [ "locations = pi.getLocations(filterId='f_ruw_gevalideerd.ADV')\n", "locations" ] }, { "cell_type": "code", "execution_count": 5, "metadata": {}, "outputs": [ { "data": { "text/html": [ "
\n", "\n", "\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "
D_0_waterS_0_soundS_0_eastS_0_northS_0_upT_0V_0_batteryErrCode_0Status_0Amp1_0Amp2_0Amp3_0Corr1_0Corr2_0Corr3_0Heading_0Pitch_0Roll_0
displayUnithPam/sm/sm/sm/soCV--mmm%%%ooo
idD.0.waterS.0.soundS.0.eastS.0.northS.0.upT.0V.0.batteryErrCode.0Status.0Amp1.0Amp2.0Amp3.0Corr1.0Corr2.0Corr3.0Heading.0Pitch.0Roll.0
nameWaterdruk [hPa] - noneqSnelheid geluid [m/s] - noneqSnelheid east [m/s] - noneqSnelheid north [m/s] - noneqSnelheid up [m/s] - noneqTemperatuur [°C] - noneqVoltage batterij [V] - noneqError code [-] - noneqStatus [-] - noneqAmp1 [m] - noneqAmp2 [m] - noneqAmp3 [m] - noneqCorr1 [-] - noneqCorr2 [-] - noneqCorr3 [-] - noneqHeading [-] - noneqPitch [-] - noneqRoll [-] - noneq
parameterTypeinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneousinstantaneous
unithPam/sm/sm/sm/soCV--mmm%%%ooo
usesDatumfalsefalsefalsefalsefalsefalsefalsefalsefalsefalsefalsefalsefalsefalsefalsefalsefalsefalse
\n", "
" ], "text/plain": [ " D_0_water S_0_sound \\\n", "displayUnit hPa m/s \n", "id D.0.water S.0.sound \n", "name Waterdruk [hPa] - noneq Snelheid geluid [m/s] - noneq \n", "parameterType instantaneous instantaneous \n", "unit hPa m/s \n", "usesDatum false false \n", "\n", " S_0_east S_0_north \\\n", "displayUnit m/s m/s \n", "id S.0.east S.0.north \n", "name Snelheid east [m/s] - noneq Snelheid north [m/s] - noneq \n", "parameterType instantaneous instantaneous \n", "unit m/s m/s \n", "usesDatum false false \n", "\n", " S_0_up T_0 \\\n", "displayUnit m/s oC \n", "id S.0.up T.0 \n", "name Snelheid up [m/s] - noneq Temperatuur [°C] - noneq \n", "parameterType instantaneous instantaneous \n", "unit m/s oC \n", "usesDatum false false \n", "\n", " V_0_battery ErrCode_0 \\\n", "displayUnit V - \n", "id V.0.battery ErrCode.0 \n", "name Voltage batterij [V] - noneq Error code [-] - noneq \n", "parameterType instantaneous instantaneous \n", "unit V - \n", "usesDatum false false \n", "\n", " Status_0 Amp1_0 Amp2_0 \\\n", "displayUnit - m m \n", "id Status.0 Amp1.0 Amp2.0 \n", "name Status [-] - noneq Amp1 [m] - noneq Amp2 [m] - noneq \n", "parameterType instantaneous instantaneous instantaneous \n", "unit - m m \n", "usesDatum false false false \n", "\n", " Amp3_0 Corr1_0 Corr2_0 \\\n", "displayUnit m % % \n", "id Amp3.0 Corr1.0 Corr2.0 \n", "name Amp3 [m] - noneq Corr1 [-] - noneq Corr2 [-] - noneq \n", "parameterType instantaneous instantaneous instantaneous \n", "unit m % % \n", "usesDatum false false false \n", "\n", " Corr3_0 Heading_0 Pitch_0 \\\n", "displayUnit % o o \n", "id Corr3.0 Heading.0 Pitch.0 \n", "name Corr3 [-] - noneq Heading [-] - noneq Pitch [-] - noneq \n", "parameterType instantaneous instantaneous instantaneous \n", "unit % o o \n", "usesDatum false false false \n", "\n", " Roll_0 \n", "displayUnit o \n", "id Roll.0 \n", "name Roll [-] - noneq \n", "parameterType instantaneous \n", "unit o \n", "usesDatum false " ] }, "execution_count": 5, "metadata": {}, "output_type": "execute_result" } ], "source": [ "parameters = pi.getParameters(filterId='f_ruw_gevalideerd.ADV')\n", "parameters" ] }, { "cell_type": "code", "execution_count": 6, "metadata": {}, "outputs": [], "source": [ "query_parameters = pi.setQueryParameters(protocol='rest')" ] }, { "cell_type": "code", "execution_count": 7, "metadata": {}, "outputs": [], "source": [ "query_parameters.filterId('f_ruw_ongevalideerd.STB')\n", "query_parameters.locationIds(['FL65'])\n", "query_parameters.parameterIds(['H.w.0'])\n", "query_parameters.startTime(pd.datetime(2019,5,18,3,38))\n", "query_parameters.endTime(pd.datetime(2019,5,18,3,39))\n", "query_parameters.useMilliseconds(True) # new in 2017.02\n", "query_parameters.version('1.25')" ] }, { "cell_type": "code", "execution_count": 8, "metadata": {}, "outputs": [ { "data": { "text/plain": [ "{'convertDatum': False,\n", " 'importFromExternalDataSource': False,\n", " 'omitMissing': False,\n", " 'onlyHeaders': False,\n", " 'onlyManualEdits': False,\n", " 'showEnsembleMemberIds': False,\n", " 'documentVersion': '1.25',\n", " 'documentFormat': 'PI_XML',\n", " 'showStatistics': False,\n", " 'showThresholds': False,\n", " 'useDisplayUnits': True,\n", " 'filterId': 'f_ruw_ongevalideerd.STB',\n", " 'locationIds': ['FL65'],\n", " 'parameterIds': ['H.w.0'],\n", " 'startTime': '2019-05-18T03:38:00Z',\n", " 'endTime': '2019-05-18T03:39:00Z',\n", " 'useMilliseconds': True}" ] }, "execution_count": 8, "metadata": {}, "output_type": "execute_result" } ], "source": [ "query_parameters.query" ] }, { "cell_type": "code", "execution_count": 9, "metadata": {}, "outputs": [ { "data": { "text/html": [ "
\n", "\n", "\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "
moduleInstanceIdqualifierIdparameterIdunitslocationIdstationNameflagvalue
date
2019-05-18 03:38:00+00:00ruw_ongevalideerd_STBH.w.0mNAPFL65FL65 Marker Wadden Zuiderstrand0-0.147
2019-05-18 03:38:00.010000+00:00ruw_ongevalideerd_STBH.w.0mNAPFL65FL65 Marker Wadden Zuiderstrand02
2019-05-18 03:38:00.175000+00:00ruw_ongevalideerd_STBH.w.0mNAPFL65FL65 Marker Wadden Zuiderstrand01
2019-05-18 03:38:00.208000+00:00ruw_ongevalideerd_STBH.w.0mNAPFL65FL65 Marker Wadden Zuiderstrand01
2019-05-18 03:38:00.226000+00:00ruw_ongevalideerd_STBH.w.0mNAPFL65FL65 Marker Wadden Zuiderstrand01
\n", "
" ], "text/plain": [ " moduleInstanceId qualifierId \\\n", "date \n", "2019-05-18 03:38:00+00:00 ruw_ongevalideerd_STB \n", "2019-05-18 03:38:00.010000+00:00 ruw_ongevalideerd_STB \n", "2019-05-18 03:38:00.175000+00:00 ruw_ongevalideerd_STB \n", "2019-05-18 03:38:00.208000+00:00 ruw_ongevalideerd_STB \n", "2019-05-18 03:38:00.226000+00:00 ruw_ongevalideerd_STB \n", "\n", " parameterId units locationId \\\n", "date \n", "2019-05-18 03:38:00+00:00 H.w.0 mNAP FL65 \n", "2019-05-18 03:38:00.010000+00:00 H.w.0 mNAP FL65 \n", "2019-05-18 03:38:00.175000+00:00 H.w.0 mNAP FL65 \n", "2019-05-18 03:38:00.208000+00:00 H.w.0 mNAP FL65 \n", "2019-05-18 03:38:00.226000+00:00 H.w.0 mNAP FL65 \n", "\n", " stationName flag value \n", "date \n", "2019-05-18 03:38:00+00:00 FL65 Marker Wadden Zuiderstrand 0 -0.147 \n", "2019-05-18 03:38:00.010000+00:00 FL65 Marker Wadden Zuiderstrand 0 2 \n", "2019-05-18 03:38:00.175000+00:00 FL65 Marker Wadden Zuiderstrand 0 1 \n", "2019-05-18 03:38:00.208000+00:00 FL65 Marker Wadden Zuiderstrand 0 1 \n", "2019-05-18 03:38:00.226000+00:00 FL65 Marker Wadden Zuiderstrand 0 1 " ] }, "execution_count": 9, "metadata": {}, "output_type": "execute_result" } ], "source": [ "timeseries = pi.getTimeSeries(query_parameters, print_response=False)\n", "timeseries.head()" ] }, { "cell_type": "markdown", "metadata": {}, "source": [ "# Post Requests" ] }, { "cell_type": "code", "execution_count": 10, "metadata": {}, "outputs": [], "source": [ "# set some variable settings\n", "module_instance_id = 'ruw_ongevalideerd_STB\t'\n", "location_id = 'FL65'\n", "parameter_id = 'H.w.0'\n", "#timeseries['user'] = 'hoek'" ] }, { "cell_type": "code", "execution_count": 11, "metadata": {}, "outputs": [], "source": [ "import random\n", "new_index = []\n", "for ts in timeseries.index:\n", " new_index.append(ts.replace(microsecond=random.randint(0, 999)*1000))" ] }, { "cell_type": "code", "execution_count": 12, "metadata": {}, "outputs": [], "source": [ "timeseries.index = pd.DatetimeIndex(new_index)\n", "timeseries.value = 1" ] }, { "cell_type": "code", "execution_count": 13, "metadata": {}, "outputs": [ { "data": { "text/html": [ "
\n", "\n", "\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "
moduleInstanceIdqualifierIdparameterIdunitslocationIdstationNameflagvalue
2019-05-18 03:38:00.568000+00:00ruw_ongevalideerd_STBH.w.0mNAPFL65FL65 Marker Wadden Zuiderstrand01
2019-05-18 03:38:00.654000+00:00ruw_ongevalideerd_STBH.w.0mNAPFL65FL65 Marker Wadden Zuiderstrand01
2019-05-18 03:38:00.765000+00:00ruw_ongevalideerd_STBH.w.0mNAPFL65FL65 Marker Wadden Zuiderstrand01
2019-05-18 03:38:00.430000+00:00ruw_ongevalideerd_STBH.w.0mNAPFL65FL65 Marker Wadden Zuiderstrand01
2019-05-18 03:38:00.835000+00:00ruw_ongevalideerd_STBH.w.0mNAPFL65FL65 Marker Wadden Zuiderstrand01
\n", "
" ], "text/plain": [ " moduleInstanceId qualifierId \\\n", "2019-05-18 03:38:00.568000+00:00 ruw_ongevalideerd_STB \n", "2019-05-18 03:38:00.654000+00:00 ruw_ongevalideerd_STB \n", "2019-05-18 03:38:00.765000+00:00 ruw_ongevalideerd_STB \n", "2019-05-18 03:38:00.430000+00:00 ruw_ongevalideerd_STB \n", "2019-05-18 03:38:00.835000+00:00 ruw_ongevalideerd_STB \n", "\n", " parameterId units locationId \\\n", "2019-05-18 03:38:00.568000+00:00 H.w.0 mNAP FL65 \n", "2019-05-18 03:38:00.654000+00:00 H.w.0 mNAP FL65 \n", "2019-05-18 03:38:00.765000+00:00 H.w.0 mNAP FL65 \n", "2019-05-18 03:38:00.430000+00:00 H.w.0 mNAP FL65 \n", "2019-05-18 03:38:00.835000+00:00 H.w.0 mNAP FL65 \n", "\n", " stationName flag value \n", "2019-05-18 03:38:00.568000+00:00 FL65 Marker Wadden Zuiderstrand 0 1 \n", "2019-05-18 03:38:00.654000+00:00 FL65 Marker Wadden Zuiderstrand 0 1 \n", "2019-05-18 03:38:00.765000+00:00 FL65 Marker Wadden Zuiderstrand 0 1 \n", "2019-05-18 03:38:00.430000+00:00 FL65 Marker Wadden Zuiderstrand 0 1 \n", "2019-05-18 03:38:00.835000+00:00 FL65 Marker Wadden Zuiderstrand 0 1 " ] }, "execution_count": 13, "metadata": {}, "output_type": "execute_result" } ], "source": [ "timeseries.head()" ] }, { "cell_type": "code", "execution_count": 14, "metadata": {}, "outputs": [ { "name": "stderr", "output_type": "stream", "text": [ "WARNING:root: The following column names are ignored: 'locationId', 'qualifierId', 'units', 'parameterId', 'moduleInstanceId', 'stationName'. \n", " Only the following column names are accepted: 'value', 'minValue', 'maxValue', 'flag', 'flagSource', 'comment', 'user''\n" ] } ], "source": [ "# create pi-timeseries object\n", "pi_ts = pi.setPiTimeSeries()\n", "\n", "# set the root version\n", "pi_ts.write.root.version('1.25')\n", "\n", "# set a header object\n", "pi_ts.write.header.moduleInstanceId(module_instance_id)\n", "pi_ts.write.header.locationId(location_id)\n", "pi_ts.write.header.parameterId(parameter_id)\n", "\n", "# set an events object (pandas.Series or pandas.DataFrame)\n", "pi_ts.write.events(timeseries)\n", "pi_ts_xml = pi_ts.to.pi_xml()" ] }, { "cell_type": "code", "execution_count": 15, "metadata": {}, "outputs": [ { "name": "stdout", "output_type": "stream", "text": [ "External time series successfully mapped to FEWS time series FL65 H.w.0 nonequidistant\n", "1 time series imported, 0 time series rejected\n", "The following locations-parameter combination imported FL65:H.w.0\n" ] } ], "source": [ "filterId='f_ruw_ongevalideerd.STB'\n", "convertDatum=True\n", "pi.postTimeSeries(filterId=filterId, piTimeSeriesXmlContent=pi_ts_xml, convertDatum=convertDatum)" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [] } ], "metadata": { "kernelspec": { "display_name": "Python 3", "language": "python", "name": "python3" }, "language_info": { "codemirror_mode": { "name": "ipython", "version": 3 }, "file_extension": ".py", "mimetype": "text/x-python", "name": "python", "nbconvert_exporter": "python", "pygments_lexer": "ipython3", "version": "3.7.1" } }, "nbformat": 4, "nbformat_minor": 4 }