Support for Qdrant API key

[toliver38]

I'd like to be able to leverage QDrant Cloud service but need to be able to pass in an API key

class Processor(ConsumerProducer):

    def __init__(self, **params):

        input_queue = params.get("input_queue", default_input_queue)
        output_queue = params.get("output_queue", default_output_queue)
        subscriber = params.get("subscriber", default_subscriber)
        store_uri = params.get("store_uri", default_store_uri)

        super(Processor, self).__init__(
            **params | {
                "input_queue": input_queue,
                "output_queue": output_queue,
                "subscriber": subscriber,
                "input_schema": GraphEmbeddingsRequest,
                "output_schema": GraphEmbeddingsResponse,
                "store_uri": store_uri,
            }
        )

        self.client = QdrantClient(url=store_uri)

Ideally this is passed as an env variable or in the command line.

qdrant_client = QdrantClient(
    "xyz-example.cloud-region.cloud-provider.cloud.qdrant.io",
    api_key="<paste-your-api-key-here>",
)

[toliver38]

https://github.com/trustgraph-ai/trustgraph/blob/042108504ee82f7c2c88e0473b4d32aae44aa0b0/trustgraph-flow/trustgraph/query/graph_embeddings/qdrant/service.py#L25C1-L46C1