Add kafka_python library to the Python action runtime (#1829)
* Add kafka_python library to the Python action runtime
* Update doc and Python package sniff test
Please squash into previous commit
diff --git a/tests/src/actionContainers/PythonActionContainerTests.scala b/tests/src/actionContainers/PythonActionContainerTests.scala
index 94bb4b9..e62b7b3 100644
--- a/tests/src/actionContainers/PythonActionContainerTests.scala
+++ b/tests/src/actionContainers/PythonActionContainerTests.scala
@@ -210,6 +210,7 @@
|import simplejson as json
|from twisted.internet import protocol, reactor, endpoints
|import socket
+ |from kafka import BrokerConnection
|
|def main(args):
| socket.setdefaulttimeout(120)
@@ -218,6 +219,7 @@
| t = parse('2016-02-22 11:59:00 EST')
| r = requests.get('https://openwhisk.ng.bluemix.net/api/v1')
| j = json.dumps({'foo':'bar'}, separators = (',', ':'))
+ | kafka = BrokerConnection("it works", 9093, None)
|
| return {
| "bs4": str(b.title),
@@ -225,7 +227,8 @@
| "dateutil": t.strftime("%A"),
| "lxml": etree.Element("root").tag,
| "json": j,
- | "request": r.status_code
+ | "request": r.status_code,
+ | "kafka_python": kafka.host
| }
""".stripMargin
@@ -242,7 +245,8 @@
"dateutil" -> "Monday".toJson,
"lxml" -> "root".toJson,
"json" -> JsObject("foo" -> "bar".toJson).compactPrint.toJson,
- "request" -> 200.toJson)))
+ "request" -> 200.toJson,
+ "kafka_python" -> "it works".toJson)))
}
checkStreams(out, err, {
