# Synchronous Example
import novu_py
from novu_py import Novu
import os
with Novu(
secret_key=os.getenv("NOVU_SECRET_KEY", ""),
) as novu:
res = novu.trigger(trigger_event_request_dto=novu_py.TriggerEventRequestDto(
workflow_id="workflow_identifier",
to={
"subscriber_id": "subscriber_unique_identifier",
"first_name": "Albert",
"last_name": "Einstein",
"email": "albert@einstein.com",
},
payload={
"comment_id": "string",
"post": {
"text": "string",
},
},
overrides={
"email": {
"bcc": "no-reply@novu.co"
}
},
))
# Handle response
print(res)
# Asynchronous Example
import asyncio
import novu_py
from novu_py import Novu
import os
async def main():
async with Novu(
secret_key=os.getenv("NOVU_SECRET_KEY", ""),
) as novu:
res = await novu.trigger_async(trigger_event_request_dto=novu_py.TriggerEventRequestDto(
workflow_id="workflow_identifier",
to={
"subscriber_id": "subscriber_unique_identifier",
"first_name": "Albert",
"last_name": "Einstein",
"email": "albert@einstein.com",
},
payload={
"comment_id": "string",
"post": {
"text": "string",
},
},
overrides={
"email": {
"bcc": "no-reply@novu.co",
}
},
))
# Handle response
print(res)
asyncio.run(main())