from prefect import Flow, task
import pymongo


@task(log_stdout=True)
def insert_document():
    myclient = pymongo.MongoClient("<mongodb://localhost:27017/>")
    mydb = myclient["mydatabase"]
    mycol = mydb["users"]
    mydict = {"name": "Marvin", "address": "Chicago 42"}
    x = mycol.insert_one(mydict)


with Flow("flow_pymongo") as flow:
    hw = insert_document()

if __name__ == "__main__":
    flow.run()