Могу ли я создать собственное преобразование Pub / Sub I / O в Python, в котором я могу передать и использовать RuntimeValueProvider?

Question

Я пытаюсь создать шаблон конвейера Pub / Sub to BigQuery в Python, и мне нужен пользовательский ввод-вывод, чтобы я мог передавать значения во время выполнения.

Я попытался понять существующий код pubsubio, предоставленныйApache Beam, но он говорит, что использует собственный источник, который переопределяется реализацией для Pub / Sub.