Merge branch 'dev'

Author: elprans

.flake8

@@ -1,5 +1,5 @@
 [flake8]
-ignore = E402,E731
+ignore = W503,E402,E731
 exclude =
     .git, __pycache__, build, dist, .eggs, .github, .local,
-    Samples, azure/worker/protos/, docs/
+    Samples, azure/functions_worker/protos/, docs/

README.md

@@ -1,21 +1,60 @@
 [![Build Status](https://travis-ci.org/Azure/azure-functions-python-worker.svg?branch=dev)](https://travis-ci.org/Azure/azure-functions-python-worker)
 [![Build status](https://ci.appveyor.com/api/projects/status/github/azure/azure-functions-python-worker?svg=true&branch=dev)](https://ci.appveyor.com/project/appsvc/azure-functions-python-worker)
 
-This repository will host the Python language worker impelementation for Azure Functions. We'll also be using it to track work items related to first class Python support. Feel free to leave comments about any of the features/design patterns.
+This repository will host the Python language worker implementation for Azure Functions. We'll also be using it to track work items related to Python support. Please feel free to leave comments about any of the features and design patterns.
 
-# Getting Started
-#### Creating a Python Function : [Developer guide](https://pythondeveloperguide.azurewebsites.net/)
-#### Understanding how things work : [Python language worker](https://github.com/Azure/azure-functions-python-worker/wiki/Worker-Architecture)
+> :construction: The project is currently **work in progress**. Please **do not use in production** as we expect developments over time. :construction:
 
-# Disclaimer
-The project is currently in progress. Please expect the feature and design patterns to develop or change over time. If you have any feedback or requests, you can file an issue or add comments.
+# Overview
 
-# Contributing
+Python support for Functions is based on [Python3.6](https://www.python.org/downloads/release/python-360/), [Functions on Linux](https://blogs.msdn.microsoft.com/appserviceteam/2017/11/15/functions-on-linux-preview/) and the [V2 Runtime](https://docs.microsoft.com/en-us/azure/azure-functions/functions-versions).
+
+Here is the current status of Python in Azure Functions:
+
+What's available?
+
+- Develop using Functions Core Tools (CLI)
+- Publish your Python functions using a Linux App Service Plan
+- Triggers / Bindings : HTTP/Webhook, Blob, Queue, Timer and Cosmos DB
+- Publish a custom image to Azure
+
+What's coming?
+
+- Publish your Python functions using the consumption (serverless) plan
+- Build, test, debug and publish using Visual Studio Code
+- Triggers / Bindings : Event Grid, Event Hubs, IoT Hub
+
+# Get Started
+
+- [Build and publish using the Functions Core Tools](https://github.com/Azure/azure-functions-python-worker/wiki/Create-Function-(CLI))
+- [Python developer guide](https://pythondeveloperguide.azurewebsites.net/)
+- [Binding API reference](https://pythondeveloperguide.azurewebsites.net/api.html#azure-functions-reference)
+
+# Give Feedback
+
+Issues and feature requests are tracked in a variety of places. To report this feedback, please file an issue to the relevant respository below:
+
+|Item|Description|Link|
+|----|-----|-----|
+| Python Worker | Programming Model, Triggers & Bindings |[File an Issue](https://github.com/Azure/azure-functions-python-worker/issues)|
+| Linux | Base Docker Images |[File an Issue](https://github.com/Azure/azure-functions-docker/issues)|
+| Runtime | Script Host & Language Extensibility |[File an Issue](https://github.com/Azure/azure-functions-host/issues)|
+| Core Tools | Command line interface for local development |[File an Issue](https://github.com/Azure/azure-functions-core-tools/issues)|
+| Portal | User Interface or Experience Issue |[File an Issue](https://github.com/azure/azure-functions-ux/issues)|
+| Templates | Code Issues with Creation Template |[File an Issue](https://github.com/Azure/azure-functions-templates/issues)|
+
+# Contribute
 
 This project welcomes contributions and suggestions.  Most contributions require you to agree to a
 Contributor License Agreement (CLA) declaring that you have the right to, and actually do, grant us
 the rights to use your contribution. For details, visit https://cla.microsoft.com.
 
+Here are some pointers to get started:
+
+- [Language worker architecture](https://github.com/Azure/azure-functions-python-worker/wiki/Worker-Architecture)
+- [Setting up the development environment](https://github.com/Azure/azure-functions-python-worker/wiki/Contributor-Guide)
+- [Adding support for a new binding](https://github.com/Azure/azure-functions-python-worker/wiki/Adding-support-for-a-new-binding-type)
+
 When you submit a pull request, a CLA-bot will automatically determine whether you need to provide
 a CLA and decorate the PR appropriately (e.g., label, comment). Simply follow the instructions
 provided by the bot. You will only need to do this once across all repos using our CLA.

azure/functions/__init__.py

@@ -1,4 +1,6 @@
 from ._abc import HttpRequest, TimerRequest, InputStream, Context, Out  # NoQA
+from ._abc import EventHubEvent  # NoQA
+from ._abc import EventGridEvent  # NoQA
 from ._cosmosdb import Document, DocumentList  # NoQA
 from ._http import HttpResponse  # NoQA
 from ._queue import QueueMessage  # NoQA

azure/functions/_abc.py

@@ -199,7 +199,44 @@ def pop_receipt(self) -> typing.Optional[str]:
         pass
 
 
+class EventGridEvent(abc.ABC):
+    @property
+    @abc.abstractmethod
+    def id(self) -> str:
+        pass
+
+    @abc.abstractmethod
+    def get_json(self) -> typing.Any:
+        pass
+
+    @property
+    @abc.abstractmethod
+    def topic(self) -> str:
+        pass
+
+    @property
+    @abc.abstractmethod
+    def subject(self) -> str:
+        pass
+
+    @property
+    @abc.abstractmethod
+    def event_type(self) -> str:
+        pass
+
+    @property
+    @abc.abstractmethod
+    def event_time(self) -> datetime.datetime:
+        pass
+
+    @property
+    @abc.abstractmethod
+    def data_version(self) -> str:
+        pass
+
+
 class Document(abc.ABC):
+
     @classmethod
     @abc.abstractmethod
     def from_json(cls, json_data: str) -> 'Document':
@@ -225,3 +262,30 @@ def to_json(self) -> str:
 
 class DocumentList(abc.ABC):
     pass
+
+
+class EventHubEvent(abc.ABC):
+
+    @abc.abstractmethod
+    def get_body(self) -> bytes:
+        pass
+
+    @property
+    @abc.abstractmethod
+    def partition_key(self) -> typing.Optional[str]:
+        pass
+
+    @property
+    @abc.abstractmethod
+    def sequence_number(self) -> typing.Optional[int]:
+        pass
+
+    @property
+    @abc.abstractmethod
+    def enqueued_time(self) -> typing.Optional[datetime.datetime]:
+        pass
+
+    @property
+    @abc.abstractmethod
+    def offset(self) -> typing.Optional[str]:
+        pass

azure/functions/_cosmosdb.py

@@ -23,7 +23,7 @@ def from_json(cls, json_data: str) -> 'Document':
     def from_dict(cls, dct: dict) -> 'Document':
         """Create a Document from a dict object."""
         filtered = {k: v for k, v in dct.items() if k not in _SYSTEM_KEYS}
-        return cls(filtered)  # type: ignore
+        return cls(filtered)
 
     def to_json(self) -> str:
         """Return the JSON representation of the document."""

azure/worker/__init__.py azure/functions_worker/__init__.pyazure/worker/__init__.py renamed to azure/functions_worker/__init__.py

@@ -9,6 +9,8 @@
 # to get them registered and available:
 from . import blob  # NoQA
 from . import cosmosdb  # NoQA
+from . import eventgrid  # NoQA
+from . import eventhub  # NoQA
 from . import http  # NoQA
 from . import queue  # NoQA
 from . import timer  # NoQA