Fabric Functions Python Worker

介绍

本项目包含必要的绑定和中间件，我们可以在Python函数上注册，以便从我们的worker扩展接收fabric数据。

Fabric项目绑定

通过导入fabric_item_input绑定，用户可以向他们的fabric函数添加一个新属性。此输入具有与宿主扩展的FabricItem属性和绑定相同的属性，并将传递到worker以创建FabricItem信息。

class FabricItem:
    def __init__(self, aliasName: str, connectionString: str, fabricItemType: ItemType, endpoints: typing.Dict[str, Endpoint]):
        self.__aliasName = aliasName
        self.__connectionString = connectionString
        self.__fabricItemType = fabricItemType
        self.__endpoints = endpoints

其中Endpoint是一个包含字符串ConnectionString和AccessToken的类

根据输入绑定中指定的itemType，我们可以将项目类型映射到默认的FabricItem、FabricSqlConnection（用于SQL或数据市场）或FabricLakehouseFilesClient（用于LakeHouse文件）。

@fabric_item_input(app, argName="myDatamart", alias="MyDatamart", item_type=ItemType.Datamart)
@app.route(route="hello_fabric")
def hello_fabric(req: func.HttpRequest, myDatamart: FabricSqlConnection) -> func.HttpResponse:
    logging.info('Python HTTP trigger function processed a request.')
    conn = myDatamart.connect()

    # Use pyodbc connection

    currentTime = datetime.datetime.now()

    return func.HttpResponse(f"Hello Fabric. The current time is {currentTime.time()}.")