{ "cells": [ { "cell_type": "code", "execution_count": 1, "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", "
node_idquery_idstateusersourcequeryqueued_time_msanalysis_time_msdistributed_planning_time_mscreatedstartedlast_heartbeatend
0ffffffff-ffff-ffff-ffff-ffffffffffff20180526_115416_00010_nwiisRUNNINGsatybaldpyhiveselect * from queries limit 111702018-05-26 13:54:16.6542018-05-26 13:54:16.6752018-05-26 13:54:16.656None
\n", "
" ], "text/plain": [ " node_id query_id state \\\n", "0 ffffffff-ffff-ffff-ffff-ffffffffffff 20180526_115416_00010_nwiis RUNNING \n", "\n", " user source query queued_time_ms \\\n", "0 satybald pyhive select * from queries limit 1 1 \n", "\n", " analysis_time_ms distributed_planning_time_ms created \\\n", "0 17 0 2018-05-26 13:54:16.654 \n", "\n", " started last_heartbeat end \n", "0 2018-05-26 13:54:16.675 2018-05-26 13:54:16.656 None " ] }, "execution_count": 1, "metadata": {}, "output_type": "execute_result" } ], "source": [ "import pandas as pd\n", "from sqlalchemy.engine import create_engine\n", "\n", "# Presto\n", "engine = create_engine('presto://localhost:8080/system/runtime') \n", "\n", "#Read Presto Data query into a DataFrame\n", "df = pd.read_sql('select * from queries limit 1', engine)\n", "df.head()" ] } ], "metadata": { "kernelspec": { "display_name": "Python 2", "language": "python", "name": "python2" }, "language_info": { "codemirror_mode": { "name": "ipython", "version": 2 }, "file_extension": ".py", "mimetype": "text/x-python", "name": "python", "nbconvert_exporter": "python", "pygments_lexer": "ipython2", "version": "2.7.12" } }, "nbformat": 4, "nbformat_minor": 2 }