Imagine you are designing a data pipeline for a financial services company that needs to process and analyze large volumes of transaction data in real-time. The data includes both structured data from databases and unstructured data from emails and chat logs. Describe how you would design this pipeline, focusing on the technologies you would use to handle the real-time processing and the intermediate staging locations for data.