From 16f1b31ba4a03fc886205c7b8f882808dffc970c Mon Sep 17 00:00:00 2001 From: Willem Pienaar Date: Fri, 30 Oct 2020 16:36:49 +0800 Subject: [PATCH 1/3] Add confluent kafka installation --- infra/docker/jupyter/Dockerfile | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/infra/docker/jupyter/Dockerfile b/infra/docker/jupyter/Dockerfile index 6396784a387..3037a4a83e1 100644 --- a/infra/docker/jupyter/Dockerfile +++ b/infra/docker/jupyter/Dockerfile @@ -18,7 +18,7 @@ RUN pip install -r sdk/python/requirements-ci.txt COPY .git .git COPY README.md README.md RUN pip install -e sdk/python -U -RUN pip install "s3fs" "boto3" "urllib3>=1.25.4" +RUN pip install "s3fs" "boto3" "urllib3>=1.25.4" "confluent_kafka" # Switch back to original user and workdir USER $NB_UID From ab9fbca8d4b8369b923e62cafa0ca06f6d4aea0b Mon Sep 17 00:00:00 2001 From: Willem Pienaar Date: Fri, 30 Oct 2020 16:42:01 +0800 Subject: [PATCH 2/3] Add Kafka installation to notebook --- ...{Feast 101.ipynb => minimal_ride_hailing.ipynb} | 14 ++++++++++++++ infra/docker/jupyter/Dockerfile | 2 +- 2 files changed, 15 insertions(+), 1 deletion(-) rename examples/minimal/{Feast 101.ipynb => minimal_ride_hailing.ipynb} (99%) diff --git a/examples/minimal/Feast 101.ipynb b/examples/minimal/minimal_ride_hailing.ipynb similarity index 99% rename from examples/minimal/Feast 101.ipynb rename to examples/minimal/minimal_ride_hailing.ipynb index 4b804185323..3593de9109b 100644 --- a/examples/minimal/Feast 101.ipynb +++ b/examples/minimal/minimal_ride_hailing.ipynb @@ -1157,6 +1157,20 @@ "With a streaming source, we can use Feast SDK to launch a Spark streaming job that continuously update the online store. First, we will update `driver_trips` feature table such that a new streaming source is added." ] }, + { + "cell_type": "code", + "execution_count": null, + "outputs": [], + "source": [ + "!pip install confluent_kafka" + ], + "metadata": { + "collapsed": false, + "pycharm": { + "name": "#%%\n" + } + } + }, { "cell_type": "code", "execution_count": 27, diff --git a/infra/docker/jupyter/Dockerfile b/infra/docker/jupyter/Dockerfile index 3037a4a83e1..6396784a387 100644 --- a/infra/docker/jupyter/Dockerfile +++ b/infra/docker/jupyter/Dockerfile @@ -18,7 +18,7 @@ RUN pip install -r sdk/python/requirements-ci.txt COPY .git .git COPY README.md README.md RUN pip install -e sdk/python -U -RUN pip install "s3fs" "boto3" "urllib3>=1.25.4" "confluent_kafka" +RUN pip install "s3fs" "boto3" "urllib3>=1.25.4" # Switch back to original user and workdir USER $NB_UID From 6eaf9a1411673b7db434c14f9f69675ef567b69b Mon Sep 17 00:00:00 2001 From: Willem Pienaar Date: Fri, 30 Oct 2020 16:43:49 +0800 Subject: [PATCH 3/3] Update title to minimal ride-hailing example --- examples/minimal/minimal_ride_hailing.ipynb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/minimal/minimal_ride_hailing.ipynb b/examples/minimal/minimal_ride_hailing.ipynb index 3593de9109b..fd6b1d963ef 100644 --- a/examples/minimal/minimal_ride_hailing.ipynb +++ b/examples/minimal/minimal_ride_hailing.ipynb @@ -4,7 +4,7 @@ "cell_type": "markdown", "metadata": {}, "source": [ - "# Feast 101 - Driver Trips Example" + "# Minimal Ride Hailing Example" ] }, {