How to create an upload session?

[Pawel Szmajda (paulschmeida)]

Based on the suggestion in #40, I've tried to create an upload session like this:

async def create_upload_session(): resp = await client.drives.by_drive_id('driveId').items.by_drive_item_id('root:/{item-path}:').create_upload_session().post()
asyncio.run(create_upload_session())

but I get this: TypeError: 'CreateUploadSessionRequestBuilder' object is not callable

so I've changed it to:

upload_session = await client.drives.by_drive_id(rds_drive_id).items.by_drive_item_id(f"root:{destination_full_path}:").create_upload_session.post()

but then I get TypeError: body cannot be null.

Can you provide an example on how to properly create an upload session?

[Shem Ogumbe (shemogumbe)]

Hello @paulschmeida thanks for using the SDK and for asking this.

To create an upload session, we use the CreateUploadSessionPostRequestBody
It takes DriveItemUploadableProperties

Examples:

frommsgraph.generated.drives.item.items.item.create_upload_session.create_upload_session_post_request_bodyimportCreateUploadSessionPostRequestBodyfrommsgraph.generated.models.drive_item_uploadable_propertiesimportDriveItemUploadablePropertiesdestination_path="my_docs/test_upload_file.txt"file_path="C:/Users/<path-to>/Project_workbook.xlsx"asyncdefupload_file():
uploadable_properties=DriveItemUploadableProperties(
additional_data={'@microsoft.graph.conflictBehavior': 'replace'})
upload_session_request_body=CreateUploadSessionPostRequestBody(
item=uploadable_properties)
print(f"Uploadable Properties: {uploadable_properties.additional_data}")
# can be used for normal drive uploadstry:
upload_session=awaituser_client.drives.by_drive_id(
"<your-drive-id>"
).items.by_drive_item_id('root:/Project/test_excel_upload.xlsx:'
).create_upload_session.post(
upload_session_request_body)
# print(f"Upload Session URL: {upload_session.upload_url}")print(dir(upload_session))
# upload_session.put_file(file, destination_path)print(
f"Upload Session EXPIRATION DATE TIME: {upload_session.expiration_date_time}"
)
print(
f"Upload Session ADDITIONAL DATA: {upload_session.additional_data}"
)
exceptAPIErrorasex:
print(f"Error creating upload session: {ex}")
asyncio.run(upload_file())

You can then use PUT request on the upload_session following https://learn.microsoft.com/en-us/graph/api/driveitem-createuploadsession?view=graph-rest-1.0

Response:

Uploadable Properties: {'@microsoft.graph.conflictBehavior': 'replace'}
Upload Session EXPIRATION DATE TIME: 2024-08-26 14:34:26.885000+00:00
Upload Session ADDITIONAL DATA: {'@odata.context': 'https://graph.microsoft.com/v1.0/$metadata#microsoft.graph.uploadSession'}

[rubyff]

Hi, many thanks for this answer! I'm not fully clear on how to use the SDK for the next stage in the process (PUT request) following the link you shared. I noticed the commented out portion here: # upload_session.put_file(file, destination_path), but UploadSession does not have a put_file method.

[Stella (InterStella0)]

After the post request you have to use PUT with the upload url, i also find that put_file doesnt exist, so i wrote one myself using httpx

asyncdefput_file(filepath, upload_url):
asyncwithhttpx.AsyncClient() ashttp_client, open(filepath) asfile:
file_size=os.path.getsize(filepath)
chunk_size=327_680# 320 KBstart=0whilestart<file_size:
chunk=file.read(chunk_size)
end=start+len(chunk) -1response=awaithttp_client.put(
upload_url,
headers={
"Content-Type": "application/octet-stream",
"Content-Length": str(len(chunk)),
"Content-Range": f"bytes {start}-{end}/{file_size}",
},
content=chunk,
)
response.raise_for_status()
start+=len(chunk)
...
# Based on his example after post()awaitput_file(file_path, upload_session.upload_url)

[Kajeepan Kandeepan (Kallepan)]

This was really helpful! Thanks!