azure_data_tables_quickstart_create_upsert_query_entities.py

1import os
2from azure.data.tables import TableServiceClient, TableClient
3from azure.core.exceptions import ResourceExistsError, HttpResponseError
4
5# Replace with your connection string
6CONNECTION_STRING = "DefaultEndpointsProtocol=https;AccountName=<your_account_name>;AccountKey=<your_account_key>;EndpointSuffix=core.windows.net"
7TABLE_NAME = "OfficeSupplies"
8
9def main():
10    try:
11        # Create the TableServiceClient
12        service_client = TableServiceClient.from_connection_string(conn_str=CONNECTION_STRING)
13
14        # Create the table
15        try:
16            table_client = service_client.create_table(table_name=TABLE_NAME)
17            print(f"Table {TABLE_NAME} created.")
18        except ResourceExistsError:
19            print(f"Table {TABLE_NAME} already exists.")
20            table_client = service_client.get_table_client(table_name=TABLE_NAME)
21
22        # Create an entity
23        my_entity = {
24            "PartitionKey": "Inventory",
25            "RowKey": "001",
26            "Product": "Marker",
27            "Price": 5.0,
28            "Quantity": 100
29        }
30
31        # Upsert the entity
32        table_client.upsert_entity(entity=my_entity)
33        print("Entity upserted.")
34
35        # Query entities
36        print("Querying entities...")
37        entities = table_client.query_entities(query_filter="PartitionKey eq 'Inventory'")
38        for entity in entities:
39            print(f"Product: {entity['Product']}, Price: {entity['Price']}")
40
41    except HttpResponseError as e:
42        print(f"An error occurred: {e.message}")
43
44if __name__ == "__main__":
45    main()