Add support for table input & output

src/input.ts

@@ -8,6 +8,8 @@ import {
     GenericInputOptions,
     StorageBlobInput,
     StorageBlobInputOptions,
+    TableInput,
+    TableInputOptions,
 } from '@azure/functions';
 import { addBindingName } from './addBindingName';
 
@@ -18,6 +20,13 @@ export function storageBlob(options: StorageBlobInputOptions): StorageBlobInput
     });
 }
 
+export function table(options: TableInputOptions): TableInput {
+    return addInputBindingName({
+        ...options,
+        type: 'table',
+    });
+}
+
 export function cosmosDB(options: CosmosDBInputOptions): CosmosDBInput {
     return addInputBindingName({
         ...options,

src/output.ts

@@ -20,6 +20,8 @@ import {
     StorageBlobOutputOptions,
     StorageQueueOutput,
     StorageQueueOutputOptions,
+    TableOutput,
+    TableOutputOptions,
 } from '@azure/functions';
 import { addBindingName } from './addBindingName';
 
@@ -37,6 +39,13 @@ export function storageBlob(options: StorageBlobOutputOptions): StorageBlobOutpu
     });
 }
 
+export function table(options: TableOutputOptions): TableOutput {
+    return addOutputBindingName({
+        ...options,
+        type: 'table',
+    });
+}
+
 export function storageQueue(options: StorageQueueOutputOptions): StorageQueueOutput {
     return addOutputBindingName({
         ...options,

types/InvocationContext.d.ts

@@ -8,6 +8,7 @@ import { HttpOutput, HttpResponse } from './http';
 import { FunctionInput, FunctionOutput, FunctionTrigger } from './index';
 import { ServiceBusQueueOutput, ServiceBusTopicOutput } from './serviceBus';
 import { StorageBlobInput, StorageBlobOutput, StorageQueueOutput } from './storage';
+import { TableInput, TableOutput } from './table';
 
 /**
  * Contains metadata and helper methods specific to this invocation
@@ -108,6 +109,12 @@ export interface InvocationContextExtraInputs {
      */
     get(input: StorageBlobInput): unknown;
 
+    /**
+     * Get a secondary table input for this invocation
+     * @input the configuration object for this table input
+     */
+    get(input: TableInput): unknown;
+
     /**
      * Get a secondary Cosmos DB documents input for this invocation
      * @input the configuration object for this Cosmos DB input
@@ -146,6 +153,13 @@ export interface InvocationContextExtraOutputs {
      */
     set(output: StorageBlobOutput, blob: unknown): void;
 
+    /**
+     * Set a secondary table output for this invocation
+     * @output the configuration object for this table output
+     * @tableEntity the table output value
+     */
+    set(output: TableOutput, tableEntity: unknown): void;
+
     /**
      * Set a secondary storage queue entry output for this invocation
      * @output the configuration object for this storage queue output

types/index.d.ts

@@ -16,6 +16,7 @@ export * as input from './input';
 export * as output from './output';
 export * from './serviceBus';
 export * from './storage';
+export * from './table';
 export * from './timer';
 export * as trigger from './trigger';
 

types/input.d.ts

@@ -5,12 +5,18 @@ import { CosmosDBInput, CosmosDBInputOptions } from './cosmosDB';
 import { GenericInputOptions } from './generic';
 import { FunctionInput } from './index';
 import { StorageBlobInput, StorageBlobInputOptions } from './storage';
+import { TableInput, TableInputOptions } from './table';
 
 /**
  * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-storage-blob-input?pivots=programming-language-javascript)
  */
 export function storageBlob(options: StorageBlobInputOptions): StorageBlobInput;
 
+/**
+ * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-storage-table-input?pivots=programming-language-javascript)
+ */
+export function table(options: TableInputOptions): TableInput;
+
 /**
  * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-cosmosdb-v2-input?pivots=programming-language-javascript)
  */

types/output.d.ts

@@ -14,6 +14,7 @@ import {
     ServiceBusTopicOutputOptions,
 } from './serviceBus';
 import { StorageBlobOutput, StorageBlobOutputOptions, StorageQueueOutput, StorageQueueOutputOptions } from './storage';
+import { TableOutput, TableOutputOptions } from './table';
 
 /**
  * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-http-webhook-output?&pivots=programming-language-javascript)
@@ -25,6 +26,11 @@ export function http(options: HttpOutputOptions): HttpOutput;
  */
 export function storageBlob(options: StorageBlobOutputOptions): StorageBlobOutput;
 
+/**
+ * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-storage-table-output?pivots=programming-language-javascript)
+ */
+export function table(options: TableOutputOptions): TableOutput;
+
 /**
  * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-storage-queue-output?pivots=programming-language-javascript)
  */

types/table.d.ts

@@ -0,0 +1,60 @@
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License.
+
+import { FunctionInput, FunctionOutput } from './index';
+
+export interface TableOutputOptions {
+    /**
+     * The table name
+     */
+    tableName: string;
+
+    /**
+     * An app setting (or environment variable) with the storage connection string to be used by this table output
+     */
+    connection: string;
+
+    /**
+     * The partition key of the table entity to write.
+     */
+    partitionKey?: string;
+
+    /**
+     * The row key of the table entity to write.
+     */
+    rowKey?: string;
+}
+export type TableOutput = FunctionOutput & TableOutputOptions;
+
+export interface TableInputOptions {
+    /**
+     * The table name
+     */
+    tableName: string;
+
+    /**
+     * An app setting (or environment variable) with the storage connection string to be used by this table input
+     */
+    connection: string;
+
+    /**
+     * The partition key of the table entity to read.
+     */
+    partitionKey?: string;
+
+    /**
+     * The row key of the table entity to read. Can't be used with `take` or `filter`.
+     */
+    rowKey?: string;
+
+    /**
+     * The maximum number of entities to return. Can't be used with `rowKey`
+     */
+    take?: number;
+
+    /**
+     * An OData filter expression for the entities to return from the table. Can't be used with `rowKey`.
+     */
+    filter?: string;
+}
+export type TableInput = FunctionInput & TableInputOptions;